track().promise and flush().promise never resolves

[oluckyman]

Expected Behavior

I expect await track|flush().promise to resolve

Current Behavior

It awaits forever.

Possible Solution

I nailed down the issue is in transports/http:

          if (res.complete && responsePayload.length > 0) {
            try {
              // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
              var parsedResponsePayload = JSON.parse(responsePayload);
              var result = _this.buildResponse(parsedResponsePayload);
              console.log("RESOLVING RESULT!", result);
              resolve(result);
              return;
            } catch (_a) {
              resolve(null);
            }
          }
        });

This code never runs because res.complete is false, even though the server returns the correct result and registers the event:

{"code":200,"server_upload_time":1714999800311,"payload_size_bytes":274,"events_ingested":1}

Steps to Reproduce

import { flush, init, track, Types } from '@amplitude/analytics-node'
const client = init('my-key')
const logEvent: async () => {
    track('command', { command: 'bla bla' }, {
      user_id: userId,
    }).promise.then((res) => {
      // this func never runs
      return res
    })
    const f = flush()
    console.log(f.promise) // shows Promise { <pending> }
    console.log('now lets wait')
    const res = await f.promise
    console.log('got it', res) // never arrives to this line
}

Environment

• JS SDK Version: analytics-node@1.3.5
• Installation Method:
  via npm into Deno:

// deno.json
{
  "imports": {
    "@amplitude/analytics-node": "npm:@amplitude/analytics-node@1.3.5"
  }
}

• Browser and Version: server environment

[sosafe-ugonna-ofoegbu]

Currently having similar issue with identify().promise using package analytics-browser.
It never resolves.
Probably something related to changes made here

Amplitude-TypeScript/packages/analytics-browser/src/utils/snippet-helper.ts

Line 15 in 405e601

export const convertProxyObjectToRealObject = <T>(instance: T, queue: QueueProxy): T => {