feat: Первый релиз

Author: quickdevel

.github/workflows/publish.yml

@@ -0,0 +1,19 @@
+name: Publish
+
+on:
+  release
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+
+      - name: Setup Node
+        uses: actions/setup-node@v3
+
+      - name: Publish
+        run: npm publish
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}

.github/workflows/release.yml

@@ -0,0 +1,17 @@
+name: Release
+
+on:
+  push:
+    branches:
+      - master
+
+jobs:
+  release:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Release please
+        id: release
+        uses: google-github-actions/release-please-action@v3
+        with:
+          release-type: node
+          package-name: yc-logging-stream

.gitignore

@@ -1,4 +1,130 @@
-/example
-/node_modules
-/package-lock.json
-/pino.js
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+.pnpm-debug.log*
+
+# Diagnostic reports (https://nodejs.org/api/report.html)
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+*.lcov
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Snowpack dependency directory (https://snowpack.dev/)
+web_modules/
+
+# TypeScript cache
+*.tsbuildinfo
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional stylelint cache
+.stylelintcache
+
+# Microbundle cache
+.rpt2_cache/
+.rts2_cache_cjs/
+.rts2_cache_es/
+.rts2_cache_umd/
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variable files
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+
+# parcel-bundler cache (https://parceljs.org/)
+.cache
+.parcel-cache
+
+# Next.js build output
+.next
+out
+
+# Nuxt.js build / generate output
+.nuxt
+dist
+
+# Gatsby files
+.cache/
+# Comment in the public line in if your project uses Gatsby and not Next.js
+# https://nextjs.org/blog/next-9-1#public-directory-support
+# public
+
+# vuepress build output
+.vuepress/dist
+
+# vuepress v2.x temp and cache directory
+.temp
+.cache
+
+# Docusaurus cache and generated files
+.docusaurus
+
+# Serverless directories
+.serverless/
+
+# FuseBox cache
+.fusebox/
+
+# DynamoDB Local files
+.dynamodb/
+
+# TernJS port file
+.tern-port
+
+# Stores VSCode versions used for testing VSCode extensions
+.vscode-test
+
+# yarn v2
+.yarn/cache
+.yarn/unplugged
+.yarn/build-state.yml
+.yarn/install-state.gz
+.pnp.*

example/options.js

@@ -0,0 +1,8 @@
+module.exports = {
+  auth: {
+    oauthToken: ''
+  },
+  destination: {
+    logGroupId: ''
+  }
+}

example/pino.js

@@ -0,0 +1,32 @@
+const pino = require('pino')
+
+const options = require('./options.js')
+
+const transport = pino.transport({
+  targets: [{
+    target: 'pino/file',
+    options: {
+      destination: 'example.log'
+    }
+  },{
+    target: '../pino',
+    options
+  }]
+})
+
+const logger = pino(transport)
+
+const run = async function () {
+  for (let i = 0; i < 3; i++) {
+    logger.trace(`Example ${i} trace message`)
+    logger.debug(`Example ${i} debug message`)
+    logger.info(`Example ${i} info message`)
+    logger.warn(`Example ${i} warn message`)
+    logger.error(`Example ${i} error message`)
+    logger.fatal(`Example ${i} fatal message`)
+  }
+
+  await new Promise(resolve => setTimeout(resolve, 5000))
+}
+
+run()

example/stream.js

@@ -0,0 +1,24 @@
+const loggingStream = require('../index.js')
+
+const options = require('./options.js')
+
+const stream = loggingStream.createWriteStream(options)
+
+const run = async function () {
+  for (let i = 0; i < 10; i++) {
+    console.log('message #' + i)
+    stream.write({
+      timestamp: new Date(),
+      level: loggingStream.logLevels.INFO,
+      message: 'Example message #' + i,
+      jsonPayload: {
+        foo: 'bar',
+        i
+      }
+    })
+  }
+
+  await new Promise(resolve => setTimeout(resolve, 5000))
+}
+
+run()

index.js

@@ -7,24 +7,43 @@ const {
   },
   cloudApi: {
     logging: {
-      log_ingestion_service: { WriteRequest }
+      log_ingestion_service: { WriteRequest },
+      log_entry: {
+        LogLevel_Level: logLevels
+      }
     }
   }
 } = require('@yandex-cloud/nodejs-sdk')
 
 const createWriteStream = function (options) {
-  const session = new Session({ oauthToken: options.oauthToken })
+  // Init client and session
+  // https://github.com/yandex-cloud/nodejs-sdk#getting-started
+  const session = new Session(options.auth)
+
   const client = session.client(LogIngestionServiceClient)
 
+  // https://cloud.yandex.ru/docs/logging/api-ref/grpc/log_ingestion_service#Destination
+  const destination = {}
+  if (options.destination.logGroupId) {
+    destination.logGroupId = options.destination.logGroupId
+  } else if (options.destination.folderId) {
+    destination.folderId = options.destination.folderId
+  }
+
   const write = async function (entries) {
+    // https://cloud.yandex.ru/docs/logging/api-ref/grpc/log_ingestion_service#WriteRequest
     await client.write(WriteRequest.fromPartial({
-      destination: options.destination,
+      destination,
       entries: entries instanceof Array ? entries : [entries]
     }))
   }
 
   return new Writable({
     objectMode: true,
+    // https://cloud.yandex.ru/docs/logging/api-ref/grpc/log_ingestion_service
+    // IncomingLogEntry:
+    //   entries:
+    //     The number of elements must be in the range 1-100.
     highWaterMark: 100,
     async write (chunk, encoding, callback) {
       try {
@@ -47,4 +66,4 @@ const createWriteStream = function (options) {
   })
 }
 
-module.exports = { createWriteStream }
+module.exports = { createWriteStream, logLevels }