fix(compiler): cannot lift a class that extends a cloud resource

apps/wing/src/commands/test/test.ts

@@ -564,7 +564,7 @@ async function testTf(synthDir: string, options: TestOptions): Promise<std.TestR
 
       const testArns = await terraformOutput(synthDir, ENV_WING_TEST_RUNNER_FUNCTION_IDENTIFIERS);
       const { TestRunnerClient } = await import(testRunnerPath);
-      const runner = new TestRunnerClient(testArns);
+      const runner = new TestRunnerClient({ $tests: testArns });
 
       const allTests = await runner.listTests();
       const filteredTests = filterTests(allTests, testFilter);

docs/api/04-standard-library/cloud/topic.md

@@ -123,7 +123,7 @@ AWS implementations of `cloud.Topic` use [AWS SNS](https://docs.aws.amazon.com/s
 
 ### Topic <a name="Topic" id="@winglang/sdk.cloud.Topic"></a>
 
-A topic.
+A topic for pub/sub notifications.
 
 #### Initializers <a name="Initializers" id="@winglang/sdk.cloud.Topic.Initializer"></a>
 

examples/tests/valid/extend_counter.test.w

@@ -0,0 +1,49 @@
+bring cloud;
+bring util;
+bring expect;
+
+let global_value = "yo";
+
+class MyCounter extends cloud.Counter {
+  pub field1: num;
+  new() {
+    this.field1 = 5;
+  }
+
+  pub inflight inc() {
+    expect.equal(this.field1, 5);
+    expect.equal(global_value, "yo");
+    super.inc();
+  }
+
+  pub inflight extra1(): str {
+    return "extra1";
+  }
+}
+
+class MySuperCounter extends MyCounter {
+  pub field2: num;
+  new() {
+    this.field2 = 10;
+  }
+
+  pub inflight inc() {
+    expect.equal(this.field2, 10);
+    expect.equal(this.field1, 5);
+    expect.equal(global_value, "yo");
+    super.inc();
+  }
+
+  pub inflight extra2(): str {
+    return "extra2";
+  }
+}
+
+let c = new MySuperCounter();
+
+test "counter works" {
+  c.inc();
+  expect.equal(c.peek(), 1);
+  expect.equal(c.extra1(), "extra1");
+  expect.equal(c.extra2(), "extra2");
+}

libs/awscdk/src/api.ts

@@ -22,6 +22,14 @@ import { isAwsCdkFunction } from "./function";
  * AWS Implementation of `cloud.Api`.
  */
 export class Api extends cloud.Api implements IAwsApi {
+  /** @internal */
+  public static _toInflightType(): string {
+    return core.InflightClient.forType(
+      __filename.replace("api", "api.inflight"),
+      "ApiClient"
+    );
+  }
+
   private readonly api: WingRestApi;
   private readonly handlers: Record<string, cloud.Function> = {};
   private readonly endpoint: cloud.Endpoint;
@@ -53,7 +61,7 @@ export class Api extends cloud.Api implements IAwsApi {
     method: string,
     path: string,
     inflight: cloud.IApiEndpointHandler,
-    props?: cloud.ApiEndpointOptions,
+    props?: cloud.ApiEndpointOptions
   ): void {
     const lowerMethod = method.toLowerCase();
     const upperMethod = method.toUpperCase();
@@ -186,7 +194,7 @@ export class Api extends cloud.Api implements IAwsApi {
     inflight: cloud.IApiEndpointHandler,
     method: string,
     path: string,
-    props?: cloud.ApiEndpointOptions,
+    props?: cloud.ApiEndpointOptions
   ): cloud.Function {
     return this.addInflightHandler(inflight, method, path, props);
   }
@@ -201,7 +209,7 @@ export class Api extends cloud.Api implements IAwsApi {
     inflight: cloud.IApiEndpointHandler,
     method: string,
     path: string,
-    props?: cloud.ApiEndpointOptions,
+    props?: cloud.ApiEndpointOptions
   ): cloud.Function {
     let handler = this.handlers[inflight._id];
     if (!handler) {
@@ -214,7 +222,7 @@ export class Api extends cloud.Api implements IAwsApi {
         this,
         App.of(this).makeId(this, prefix),
         newInflight,
-        props,
+        props
       );
       this.handlers[inflight._id] = handler;
     }
@@ -229,10 +237,10 @@ export class Api extends cloud.Api implements IAwsApi {
   }
 
   /** @internal */
-  public _toInflight(): string {
-    return core.InflightClient.for(__dirname, __filename, "ApiClient", [
-      `process.env["${this.urlEnvName()}"]`,
-    ]);
+  public _liftedState(): Record<string, string> {
+    return {
+      $url: `process.env["${this.urlEnvName()}"]`,
+    };
   }
 
   private urlEnvName(): string {

libs/awscdk/src/bucket.ts

@@ -9,15 +9,15 @@ import { BucketDeployment, Source } from "aws-cdk-lib/aws-s3-deployment";
 import { LambdaDestination } from "aws-cdk-lib/aws-s3-notifications";
 import { Construct } from "constructs";
 import { App } from "./app";
-import { cloud, core, std } from "@winglang/sdk";
+import { cloud, std } from "@winglang/sdk";
 import { calculateBucketPermissions } from "@winglang/sdk/lib/shared-aws/permissions";
 import { IAwsBucket } from "@winglang/sdk/lib/shared-aws/bucket";
 import {
   IAwsCdkFunction,
   addPolicyStatements,
   isAwsCdkFunction,
 } from "./function";
-import { LiftMap, lift } from "@winglang/sdk/lib/core";
+import { LiftMap, lift, InflightClient } from "@winglang/sdk/lib/core";
 
 const EVENTS = {
   [cloud.BucketEventType.DELETE]: EventType.OBJECT_REMOVED,
@@ -31,6 +31,14 @@ const EVENTS = {
  * @inflight `@winglang/sdk.cloud.IBucketClient`
  */
 export class Bucket extends cloud.Bucket implements IAwsBucket {
+  /** @internal */
+  public static _toInflightType(): string {
+    return InflightClient.forType(
+      __filename.replace("bucket", "bucket.inflight"),
+      "BucketClient"
+    );
+  }
+
   private readonly bucket: S3Bucket;
   private readonly public: boolean;
   private bucketDeployment?: BucketDeployment;
@@ -59,7 +67,10 @@ export class Bucket extends cloud.Bucket implements IAwsBucket {
     inflight: cloud.IBucketEventHandler,
     opts?: cloud.BucketOnCreateOptions
   ): IAwsCdkFunction {
-    const functionHandler = lift({ handler: inflight, eventType: event }).inflight(async (ctx, event) => {
+    const functionHandler = lift({
+      handler: inflight,
+      eventType: event,
+    }).inflight(async (ctx, event) => {
       const record = event.Records[0];
       if (!record) {
         throw new Error("No record found in the S3 event");
@@ -112,7 +123,11 @@ export class Bucket extends cloud.Bucket implements IAwsBucket {
     inflight: cloud.IBucketEventHandler,
     opts?: cloud.BucketOnCreateOptions
   ): void {
-    const fn = this.onEventFunction(cloud.BucketEventType.CREATE, inflight, opts);
+    const fn = this.onEventFunction(
+      cloud.BucketEventType.CREATE,
+      inflight,
+      opts
+    );
 
     std.Node.of(this).addConnection({
       source: this,
@@ -130,7 +145,11 @@ export class Bucket extends cloud.Bucket implements IAwsBucket {
     inflight: cloud.IBucketEventHandler,
     opts?: cloud.BucketOnDeleteOptions
   ): void {
-    const fn = this.onEventFunction(cloud.BucketEventType.DELETE, inflight, opts);
+    const fn = this.onEventFunction(
+      cloud.BucketEventType.DELETE,
+      inflight,
+      opts
+    );
 
     std.Node.of(this).addConnection({
       source: this,
@@ -148,7 +167,11 @@ export class Bucket extends cloud.Bucket implements IAwsBucket {
     inflight: cloud.IBucketEventHandler,
     opts?: cloud.BucketOnUpdateOptions
   ): void {
-    const fn = this.onEventFunction(cloud.BucketEventType.UPDATE, inflight, opts);
+    const fn = this.onEventFunction(
+      cloud.BucketEventType.UPDATE,
+      inflight,
+      opts
+    );
 
     std.Node.of(this).addConnection({
       source: this,
@@ -189,15 +212,10 @@ export class Bucket extends cloud.Bucket implements IAwsBucket {
   }
 
   /** @internal */
-  public _toInflight(): string {
-    return core.InflightClient.for(__dirname, __filename, "BucketClient", [
-      `process.env["${this.envName()}"]`,
-      `process.env["${this.isPublicEnvName()}"]`,
-    ]);
-  }
-
-  private isPublicEnvName(): string {
-    return `${this.envName()}_IS_PUBLIC`;
+  public _liftedState(): Record<string, string> {
+    return {
+      $url: `process.env["${this.envName()}"]`,
+    };
   }
 
   private envName(): string {

libs/awscdk/src/counter.ts

@@ -1,19 +1,27 @@
 import { RemovalPolicy } from "aws-cdk-lib";
 import { AttributeType, BillingMode, Table } from "aws-cdk-lib/aws-dynamodb";
 import { Construct } from "constructs";
-import { cloud, core, std } from "@winglang/sdk";
+import { cloud, std } from "@winglang/sdk";
 import { COUNTER_HASH_KEY } from "@winglang/sdk/lib/shared-aws/commons";
 import { calculateCounterPermissions } from "@winglang/sdk/lib/shared-aws/permissions";
 import { IAwsCounter } from "@winglang/sdk/lib/shared-aws/counter";
 import { addPolicyStatements, isAwsCdkFunction } from "./function";
-import { LiftMap } from "@winglang/sdk/lib/core";
+import { InflightClient, LiftMap } from "@winglang/sdk/lib/core";
 
 /**
  * AWS implementation of `cloud.Counter`.
  *
  * @inflight `@winglang/sdk.cloud.ICounterClient`
  */
 export class Counter extends cloud.Counter implements IAwsCounter {
+  /** @internal */
+  public static _toInflightType(): string {
+    return InflightClient.forType(
+      __filename.replace("counter", "counter.inflight"),
+      "CounterClient"
+    );
+  }
+
   private readonly table: Table;
 
   constructor(scope: Construct, id: string, props: cloud.CounterProps = {}) {
@@ -52,11 +60,11 @@ export class Counter extends cloud.Counter implements IAwsCounter {
   }
 
   /** @internal */
-  public _toInflight(): string {
-    return core.InflightClient.for(__dirname, __filename, "CounterClient", [
-      `process.env["${this.envName()}"]`,
-      `${this.initial}`,
-    ]);
+  public _liftedState(): Record<string, string> {
+    return {
+      $tableName: `process.env["${this.envName()}"]`,
+      $initial: `${this.initial}`,
+    };
   }
 
   private envName(): string {

libs/awscdk/src/endpoint.ts

@@ -1,12 +1,26 @@
 import { CfnOutput } from "aws-cdk-lib";
 import { Construct } from "constructs";
-import { core, cloud, std } from "@winglang/sdk";
+import { cloud, std } from "@winglang/sdk";
+import { InflightClient } from "@winglang/sdk/lib/core";
 
 /**
  * AWS implementation of `cloud.Endpoint`.
  */
 export class Endpoint extends cloud.Endpoint {
-  constructor(scope: Construct, id: string, url: string, props: cloud.EndpointProps = {}) {
+  /** @internal */
+  public static _toInflightType(): string {
+    return InflightClient.forType(
+      __filename.replace("endpoint", "endpoint.inflight"),
+      "EndpointClient"
+    );
+  }
+
+  constructor(
+    scope: Construct,
+    id: string,
+    url: string,
+    props: cloud.EndpointProps = {}
+  ) {
     super(scope, id, url, props);
 
     new CfnOutput(this, "Url", {
@@ -21,13 +35,10 @@ export class Endpoint extends cloud.Endpoint {
   }
 
   /** @internal */
-  public _toInflight(): string {
-    return core.InflightClient.for(
-      __dirname,
-      __filename,
-      "EndpointClient",
-      [`process.env["${this.urlEnvName()}"]`]
-    );
+  public _liftedState(): Record<string, string> {
+    return {
+      $url: `process.env["${this.urlEnvName()}"]`,
+    };
   }
 
   private urlEnvName(): string {

libs/awscdk/src/function.ts

@@ -11,7 +11,7 @@ import {
 import { LogGroup, RetentionDays } from "aws-cdk-lib/aws-logs";
 import { Asset } from "aws-cdk-lib/aws-s3-assets";
 import { Construct, IConstruct } from "constructs";
-import { cloud, std, core } from "@winglang/sdk";
+import { cloud, std } from "@winglang/sdk";
 import { NotImplementedError } from "@winglang/sdk/lib/core/errors";
 import { createBundle } from "@winglang/sdk/lib/shared/bundling";
 import {
@@ -24,7 +24,7 @@ import { makeAwsLambdaHandler } from "@winglang/sdk/lib/shared-aws/function-util
 import { resolve } from "path";
 import { renameSync, rmSync, writeFileSync } from "fs";
 import { App } from "./app";
-import { LiftMap } from "@winglang/sdk/lib/core";
+import { InflightClient, LiftMap } from "@winglang/sdk/lib/core";
 
 /**
  * Implementation of `awscdk.Function` are expected to implement this
@@ -58,6 +58,14 @@ export class Function
   extends cloud.Function
   implements IAwsCdkFunction, IAwsFunction
 {
+  /** @internal */
+  public static _toInflightType(): string {
+    return InflightClient.forType(
+      __filename.replace("function", "function.inflight"),
+      "FunctionClient"
+    );
+  }
+
   private readonly function: CdkFunction;
   private readonly assetPath: string;
 
@@ -151,10 +159,11 @@ export class Function
   }
 
   /** @internal */
-  public _toInflight(): string {
-    return core.InflightClient.for(__dirname, __filename, "FunctionClient", [
-      `process.env["${this.envName()}"], "${this.node.path}"`,
-    ]);
+  public _liftedState(): Record<string, string> {
+    return {
+      $functionArn: `process.env["${this.envName()}"]`,
+      $constructPath: `"${this.node.path}"`,
+    };
   }
 
   /**