Skip to content

feat(DAPP-7422): move from lazy promise to async result #68

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Sep 23, 2025
Merged

feat(DAPP-7422): move from lazy promise to async result #68

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
452 changes: 260 additions & 192 deletions src/generated-sdk/capabilities/blockchain/evm/v1alpha/client_sdk_gen.ts
View file
Open in desktop

Large diffs are not rendered by default.

42 changes: 24 additions & 18 deletions src/generated-sdk/capabilities/internal/actionandtrigger/v1/basic_sdk_gen.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ export class BasicCapability {

constructor(private readonly mode: Mode = BasicCapability.DEFAULT_MODE) {}

async action(input: Input | InputJson): Promise<Output> {
action(input: Input | InputJson): { result: () => Promise<Output> } {
// biome-ignore lint/suspicious/noExplicitAny: Needed for runtime type checking of protocol buffer messages
const value = (input as any).$typeName
? (input as Input)
Expand All @@ -49,30 +49,36 @@ export class BasicCapability {
}
const capabilityId = BasicCapability.CAPABILITY_ID

const capabilityResponse = await callCapability({
const capabilityResponse = callCapability({
capabilityId,
method: 'Action',
mode: this.mode,
payload,
})

if (capabilityResponse.response.case === 'error') {
throw new CapabilityError(capabilityResponse.response.value, {
capabilityId,
method: 'Action',
mode: this.mode,
})
return {
result: async () => {
const { response } = await capabilityResponse.result()

if (response.case === 'error') {
throw new CapabilityError(response.value, {
capabilityId,
method: 'Action',
mode: this.mode,
})
}

if (response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'Action',
mode: this.mode,
})
}

return fromBinary(OutputSchema, response.value.value)
},
}

if (capabilityResponse.response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'Action',
mode: this.mode,
})
}

return fromBinary(OutputSchema, capabilityResponse.response.value.value)
}

trigger(config: ConfigJson): BasicTrigger {
Expand Down
40 changes: 23 additions & 17 deletions src/generated-sdk/capabilities/internal/basicaction/v1/basicaction_sdk_gen.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ export class BasicActionCapability {

constructor(private readonly mode: Mode = BasicActionCapability.DEFAULT_MODE) {}

async performAction(input: Inputs | InputsJson): Promise<Outputs> {
performAction(input: Inputs | InputsJson): { result: () => Promise<Outputs> } {
// biome-ignore lint/suspicious/noExplicitAny: Needed for runtime type checking of protocol buffer messages
const value = (input as any).$typeName
? (input as Inputs)
Expand All @@ -42,29 +42,35 @@ export class BasicActionCapability {
}
const capabilityId = BasicActionCapability.CAPABILITY_ID

const capabilityResponse = await callCapability({
const capabilityResponse = callCapability({
capabilityId,
method: 'PerformAction',
mode: this.mode,
payload,
})

if (capabilityResponse.response.case === 'error') {
throw new CapabilityError(capabilityResponse.response.value, {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}
return {
result: async () => {
const { response } = await capabilityResponse.result()

if (capabilityResponse.response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}
if (response.case === 'error') {
throw new CapabilityError(response.value, {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}

return fromBinary(OutputsSchema, capabilityResponse.response.value.value)
if (response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}

return fromBinary(OutputsSchema, response.value.value)
},
}
}
}
82 changes: 48 additions & 34 deletions src/generated-sdk/capabilities/internal/consensus/v1alpha/consensus_sdk_gen.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,9 @@ export class ConsensusCapability {

constructor(private readonly mode: Mode = ConsensusCapability.DEFAULT_MODE) {}

async simple(input: SimpleConsensusInputs | SimpleConsensusInputsJson): Promise<Value> {
simple(input: SimpleConsensusInputs | SimpleConsensusInputsJson): {
result: () => Promise<Value>
} {
// biome-ignore lint/suspicious/noExplicitAny: Needed for runtime type checking of protocol buffer messages
const value = (input as any).$typeName
? (input as SimpleConsensusInputs)
Expand All @@ -46,33 +48,39 @@ export class ConsensusCapability {
}
const capabilityId = ConsensusCapability.CAPABILITY_ID

const capabilityResponse = await callCapability({
const capabilityResponse = callCapability({
capabilityId,
method: 'Simple',
mode: this.mode,
payload,
})

if (capabilityResponse.response.case === 'error') {
throw new CapabilityError(capabilityResponse.response.value, {
capabilityId,
method: 'Simple',
mode: this.mode,
})
}
return {
result: async () => {
const { response } = await capabilityResponse.result()

if (capabilityResponse.response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'Simple',
mode: this.mode,
})
}
if (response.case === 'error') {
throw new CapabilityError(response.value, {
capabilityId,
method: 'Simple',
mode: this.mode,
})
}

return fromBinary(ValueSchema, capabilityResponse.response.value.value)
if (response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'Simple',
mode: this.mode,
})
}

return fromBinary(ValueSchema, response.value.value)
},
}
}

async report(input: ReportRequest | ReportRequestJson): Promise<ReportResponse> {
report(input: ReportRequest | ReportRequestJson): { result: () => Promise<ReportResponse> } {
// biome-ignore lint/suspicious/noExplicitAny: Needed for runtime type checking of protocol buffer messages
const value = (input as any).$typeName
? (input as ReportRequest)
Expand All @@ -83,29 +91,35 @@ export class ConsensusCapability {
}
const capabilityId = ConsensusCapability.CAPABILITY_ID

const capabilityResponse = await callCapability({
const capabilityResponse = callCapability({
capabilityId,
method: 'Report',
mode: this.mode,
payload,
})

if (capabilityResponse.response.case === 'error') {
throw new CapabilityError(capabilityResponse.response.value, {
capabilityId,
method: 'Report',
mode: this.mode,
})
}
return {
result: async () => {
const { response } = await capabilityResponse.result()

if (capabilityResponse.response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'Report',
mode: this.mode,
})
}
if (response.case === 'error') {
throw new CapabilityError(response.value, {
capabilityId,
method: 'Report',
mode: this.mode,
})
}

return fromBinary(ReportResponseSchema, capabilityResponse.response.value.value)
if (response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'Report',
mode: this.mode,
})
}

return fromBinary(ReportResponseSchema, response.value.value)
},
}
}
}
40 changes: 23 additions & 17 deletions src/generated-sdk/capabilities/internal/nodeaction/v1/basicaction_sdk_gen.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ export class BasicActionCapability {

constructor(private readonly mode: Mode = BasicActionCapability.DEFAULT_MODE) {}

async performAction(input: NodeInputs | NodeInputsJson): Promise<NodeOutputs> {
performAction(input: NodeInputs | NodeInputsJson): { result: () => Promise<NodeOutputs> } {
// biome-ignore lint/suspicious/noExplicitAny: Needed for runtime type checking of protocol buffer messages
const value = (input as any).$typeName
? (input as NodeInputs)
Expand All @@ -42,29 +42,35 @@ export class BasicActionCapability {
}
const capabilityId = BasicActionCapability.CAPABILITY_ID

const capabilityResponse = await callCapability({
const capabilityResponse = callCapability({
capabilityId,
method: 'PerformAction',
mode: this.mode,
payload,
})

if (capabilityResponse.response.case === 'error') {
throw new CapabilityError(capabilityResponse.response.value, {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}
return {
result: async () => {
const { response } = await capabilityResponse.result()

if (capabilityResponse.response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}
if (response.case === 'error') {
throw new CapabilityError(response.value, {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}

return fromBinary(NodeOutputsSchema, capabilityResponse.response.value.value)
if (response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'PerformAction',
mode: this.mode,
})
}

return fromBinary(NodeOutputsSchema, response.value.value)
},
}
}
}
40 changes: 23 additions & 17 deletions src/generated-sdk/capabilities/networking/http/v1alpha/client_sdk_gen.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ export class ClientCapability {

constructor(private readonly mode: Mode = ClientCapability.DEFAULT_MODE) {}

async sendRequest(input: Request | RequestJson): Promise<Response> {
sendRequest(input: Request | RequestJson): { result: () => Promise<Response> } {
// biome-ignore lint/suspicious/noExplicitAny: Needed for runtime type checking of protocol buffer messages
const value = (input as any).$typeName
? (input as Request)
Expand All @@ -42,29 +42,35 @@ export class ClientCapability {
}
const capabilityId = ClientCapability.CAPABILITY_ID

const capabilityResponse = await callCapability({
const capabilityResponse = callCapability({
capabilityId,
method: 'SendRequest',
mode: this.mode,
payload,
})

if (capabilityResponse.response.case === 'error') {
throw new CapabilityError(capabilityResponse.response.value, {
capabilityId,
method: 'SendRequest',
mode: this.mode,
})
}
return {
result: async () => {
const { response } = await capabilityResponse.result()

if (capabilityResponse.response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'SendRequest',
mode: this.mode,
})
}
if (response.case === 'error') {
throw new CapabilityError(response.value, {
capabilityId,
method: 'SendRequest',
mode: this.mode,
})
}

return fromBinary(ResponseSchema, capabilityResponse.response.value.value)
if (response.case !== 'payload') {
throw new CapabilityError('No payload in response', {
capabilityId,
method: 'SendRequest',
mode: this.mode,
})
}

return fromBinary(ResponseSchema, response.value.value)
},
}
}
}
Loading