fix: update libraries with Wing 0.79.0 compatibility (#291)

.mkrepo/main.w

@@ -38,7 +38,9 @@ new prlint.PullRequestLintWorkflow(workflowdir, libs.copy());
 new gitattributes.GitAttributes();
 
 let skipCanaryTests = [
-  "containers" // https://github.com/winglang/wing/issues/5716
+  "containers", // https://github.com/winglang/wing/issues/5716
+  "cognito", // https://github.com/winglang/wing/issues/6924
+  "python", // https://github.com/winglang/wing/issues/6923
 ];
 
 new canary.CanaryWorkflow(workflowdir, libs.copy(), skipCanaryTests);

checks/check.w

@@ -38,7 +38,7 @@ pub class Check impl ICheck {
     this.checkpath = nodeof(this).path;
     this.results = r.Results.of(this);
 
-    let wrapper = inflight (): str => {
+    let wrapper = inflight (): Json => {
       log("running check {this.checkpath} ({this.checkid})...");
       let ts = datetime.utcNow().toIso();
 
@@ -65,7 +65,7 @@ pub class Check impl ICheck {
 
       this.results.store(result);
 
-      return Json.stringify(result);
+      return result;
     };
 
     if props?.deploy ?? true {
@@ -92,7 +92,7 @@ pub class Check impl ICheck {
    */
   pub inflight run(): r.CheckResult {
     let result = this.invoker.invoke("")!;
-    return r.CheckResult.fromJson(Json.parse(result));
+    return r.CheckResult.fromJson(result);
   }
 
   /**

checks/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@winglibs/checks",
-  "version": "0.0.13",
+  "version": "0.0.14",
   "description": "Cloud checks",
   "publishConfig": {
     "access": "public",

fifoqueue/fifo-queue.aws.w

@@ -31,8 +31,7 @@ pub class FifoQueue_aws impl api.IFifoQueue {
 
   pub setConsumer(handler: inflight (str) : void, options: api.SetConsumerOptions?) {
     let lambdaFn = new cloud.Function(inflight (event) => {
-      let json: Json = unsafeCast(event);
-      let sqsEvent = SqsEvent.fromJson(event);
+      let sqsEvent = SqsEvent.fromJson(event!);
       for message in sqsEvent.Records {
         handler(message.body);
       }

fifoqueue/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@winglibs/fifoqueue",
-  "version": "0.0.7",
+  "version": "0.0.8",
   "description": "A wing library to work with FIFO (first-in first-out) Queues",
   "author": {
     "name": "Elad Cohen",

github/lib.w

@@ -1,6 +1,5 @@
 bring cloud;
 bring http;
-bring ex;
 bring util;
 bring "./probot/types.w" as probot;
 bring "./octokit/types.w" as octokit;

github/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@winglibs/github",
   "description": "A Wing library for GitHub Probot",
-  "version": "0.0.11",
+  "version": "0.0.12",
   "author": {
     "name": "Elad Cohen",
     "email": "[email protected]"

messagefanout/lib.test.w

@@ -1,31 +1,24 @@
 bring cloud;
 bring util;
-bring ex;
 bring "./lib.w" as msgfanout;
 
 let fanout = new msgfanout.MessageFanout();
 
-let table = new ex.Table(
-  name: "users",
-  primaryKey: "msgId",
-  columns: {
-    "message" => ex.ColumnType.STRING
-  }
-);
+let data = new cloud.Bucket();
 
 fanout.addConsumer(inflight (msg: str) => {
-  table.insert("first", { message: "first {msg}" });
+  data.putJson("first", { message: "first {msg}" });
 }, name: "first");
 
 fanout.addConsumer(inflight (msg: str) => {
-  table.insert("second", { message: "second {msg}" });
+  data.putJson("second", { message: "second {msg}" });
 }, name: "second");
 
 test "message fanout" {
   fanout.publish("hello 👋");
 
   util.sleep(10s);
 
-  assert(table.get("first")["message"] == "first hello 👋");  
-  assert(table.get("second")["message"] == "second hello 👋");
+  assert(data.getJson("first")["message"] == "first hello 👋");  
+  assert(data.getJson("second")["message"] == "second hello 👋");
 }

messagefanout/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@winglibs/messagefanout",
   "description": "Message fanout library for Wing",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "repository": {
     "type": "git",
     "url": "https://github.com/winglang/winglibs.git",

messagefanout/platform/tf-aws.w

@@ -27,9 +27,8 @@ pub class MessageFanout_tfaws impl api.IMessageFanout {
   }
 
   pub addConsumer(handler: inflight(str): void, props: api.MessageFanoutProps): void {
-    let my_function = new cloud.Function(inflight(event: str?): str? => {
-      let json: Json = unsafeCast(event);
-      let sqsEvent = SqsEvent.fromJson(event);
+    let my_function = new cloud.Function(inflight(event) => {
+      let sqsEvent = SqsEvent.fromJson(event!);
       for message in sqsEvent.Records {
         handler(message.body);
       }

sagemaker/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@winglibs/sagemaker",
-  "version": "0.0.5",
+  "version": "0.0.6",
   "description": "The library enables owners of a trained sagemaker model, to access its Endpoints from a winglang inflight code.",
   "repository": {
     "type": "git",

sagemaker/sagemaker.test.w

@@ -5,8 +5,8 @@ bring util;
 
 let sm = new sageMaker.Endpoint(util.tryEnv("ENDPOINT_NAME") ?? "Example-endopint", util.tryEnv("INFERENCE_NAME") ?? "Example-inference");
 
-let invokeModel = inflight (input: str?) => {
-  let var s = input ?? "Hi There!";
+let invokeModel = inflight (input: Json?) => {
+  let var s = input?.tryAsStr() ?? "Hi There!";
   let res = sm.invoke( { inputs: "{s}" }, { ContentType: "application/json" });
   log(res.Body);
 };

tsoa/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@winglibs/tsoa",
   "description": "TSOA library for Wing",
-  "version": "0.1.10",
+  "version": "0.1.11",
   "author": {
     "email": "[email protected]",
     "name": "Eyal Keren"

tsoa/tfaws.w

@@ -86,7 +86,7 @@ pub class Service_tfaws impl types.IService {
     );
 
     this.func = new TSOAFunction({ RegisterRoutes: res.routesFile }, inflight (event, context) => {
-      return Service_tfaws.runHandler(event, context, this.clients);
+      return Service_tfaws.runHandler(event!, context!, this.clients);
     });
 
     let awsFn = aws.Function.from(this.func.fn)!;