feat: sync support (#5)

Author: metcoder95

lib/cloud-logging.js

@@ -7,10 +7,13 @@ class CloudLogging {
     this._resource = Object.assign({ type: 'global' }, options.resourceSettings)
     this._defaultLabels = Object.assign(
       {},
-      { logger: 'pino' },
+      { logger: 'pino', agent: 'cloud_pine' },
       options.defaultLabels
     )
     this._log = null
+    // Indicates whether the logs will be forward to stdout or
+    // through networking to GCP
+    this._sync = options.sync ?? false
     this._logOptions = options.logOptions
   }
 
@@ -24,14 +27,18 @@ class CloudLogging {
     return this._resource
   }
 
+  get sync () {
+    return this._sync
+  }
+
   async init () {
     await this.logging.setProjectId()
     await this.logging.setDetectedResource()
 
     const labels = Object.assign(
       {},
       this._resource.labels,
-      this.logging.detectedResource.labels
+      this.logging.detectedResource?.labels
     )
 
     this._resource = Object.assign(
@@ -41,7 +48,10 @@ class CloudLogging {
 
     this._resource.labels = labels
 
-    this._log = this.logging.log(this.name)
+    this._log = this._sync
+      ? this.logging.logSync(this.name)
+      : this.logging.log(this.name)
+
     return this._log
   }
 
@@ -72,6 +82,8 @@ class CloudLogging {
       log.meta // Custom property to add more meta to the LogEntry
     )
 
+    delete log.meta
+
     meta.resource = Object.assign({}, this._resource, meta.resource)
     meta.labels = Object.assign({}, this._defaultLabels, meta.labels)
 
@@ -83,8 +95,7 @@ class CloudLogging {
     log.message = log.message ?? log.msg
     delete log.msg
 
-    const entry = this._log.entry(meta, log)
-    this._log.write(entry)
+    this._log.write(this._log.entry(meta, log))
   }
 }