Merge pull request #1 from victorshevtsov/feature/upgrade-to-streamr-1.0

Feature/upgrade-to-streamr-1.0

Author: rsoury

Dockerfile

@@ -1,4 +1,4 @@
-FROM node:18-slim
+FROM node:20-slim
 
 WORKDIR /home/node/airbyte
 RUN npm install -g pnpm

destinations/streamr-destination/package.json

@@ -23,25 +23,25 @@
   },
   "main": "./lib.js",
   "dependencies": {
+    "@streamr/sdk": "^100.1.2",
+    "commander": "^11.1.0",
     "faros-feeds-sdk": "^0.9.0",
     "git-url-parse": "^11.6.0",
     "jsonata": "^1.8.5",
-    "to-json-schema": "^0.2.5",
-    "object-sizeof": "^1.6.1",
     "lodash": "^4.17.21",
+    "object-sizeof": "^1.6.1",
     "rxjs": "8.0.0-alpha.12",
-    "commander": "^11.1.0",
     "sqlite": "^4.0.23",
-    "streamr-client": "^8.5.5",
+    "to-json-schema": "^0.2.5",
     "turndown": "^7.1.1"
   },
   "devDependencies": {
-    "cross-spawn": "^7.0.3",
     "@types/cross-spawn": "^6.0.5",
-    "@types/to-json-schema": "^0.2.4",
-    "temp": "^0.9.4",
+    "@types/lodash": "^4.14.201",
     "@types/temp": "^0.9.4",
+    "@types/to-json-schema": "^0.2.4",
     "@types/turndown": "^5.0.1",
-    "@types/lodash": "^4.14.201"
+    "cross-spawn": "^7.0.3",
+    "temp": "^0.9.4"
   }
 }

destinations/streamr-destination/src/index.ts

@@ -1,4 +1,6 @@
-import {Command} from "commander";
+import * as nerror from "@netflix/nerror";
+import { CONFIG_TEST, Stream, StreamrClient } from "@streamr/sdk";
+import { Command } from "commander";
 import {
   AirbyteConfig,
   AirbyteConfiguredCatalog,
@@ -15,13 +17,11 @@ import {
   AirbyteStream,
   parseAirbyteMessage,
 } from "faros-airbyte-cdk";
-import * as readline from "readline";
-import {CONFIG_TEST, Stream, StreamrClient} from "streamr-client";
-import {Dictionary} from "ts-essentials";
-import * as nerror from "@netflix/nerror";
+import { sleep } from "faros-feeds-sdk/lib/feed";
 import _ from "lodash";
-import {from, Observable, shareReplay, tap} from "rxjs";
-import {sleep} from "faros-feeds-sdk/lib/feed";
+import * as readline from "readline";
+import { Observable, from, shareReplay, tap } from "rxjs";
+import { Dictionary } from "ts-essentials";
 
 /** The main entry point. */
 export function mainCommand(options?: {
@@ -315,7 +315,7 @@ class StreamrDestination extends AirbyteDestination<ExpectedConfig> {
               this.logger.info(
                 `content: ${JSON.stringify(context.record.data)}`,
               );
-              
+
               const message =
                 config.streamNameBehavior === "STREAM_NAME_AS_DATA_PROPERTY"
                   ? {

destinations/streamr-destination/test/index.test.ts

@@ -11,7 +11,7 @@ import { CLI, read } from "./cli";
 import { tempConfig } from "./temp";
 import { sleep } from "faros-feeds-sdk/lib/feed";
 import { filter, firstValueFrom, from, map, toArray } from "rxjs";
-import { CONFIG_TEST, StreamrClient } from "streamr-client";
+import { CONFIG_TEST, StreamrClient } from "@streamr/sdk";
 
 const privateKey = process.env.PRIVATE_KEY!;
 const streamAddress = "0xd95083fbf72897f8a6607f27891e814b29d843b3";