Skip to content

Commit

Permalink
feat: quickjs plugin
Browse files Browse the repository at this point in the history
  • Loading branch information
asiaziola committed Feb 12, 2024
1 parent 5801737 commit e0ffd14
Show file tree
Hide file tree
Showing 6 changed files with 53 additions and 3 deletions.
1 change: 1 addition & 0 deletions src/contract/Contract.ts
Original file line number Diff line number Diff line change
Expand Up @@ -132,6 +132,7 @@ export interface Contract<State = unknown> {
sortKey: string,
interactions: GQLNodeInterface[],
signal?: AbortSignal
// przekazać stan (SortKeyCachedResult)
): Promise<SortKeyCacheResult<EvalStateResult<State>>>;

/**
Expand Down
1 change: 1 addition & 0 deletions src/contract/HandlerBasedContract.ts
Original file line number Diff line number Diff line change
Expand Up @@ -640,6 +640,7 @@ export class HandlerBasedContract<State> implements Contract<State> {

const benchmark = Benchmark.measure();
if (!this.isRoot()) {
// przekazać nasz gotowiec
cachedState = this.interactionState().getLessOrEqual(this.txId(), upToSortKey) as SortKeyCacheResult<
EvalStateResult<State>
>;
Expand Down
3 changes: 2 additions & 1 deletion src/core/WarpPlugin.ts
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,8 @@ export const knownWarpPlugins = [
'deploy',
'contract-blacklist',
'vm2',
'vrf'
'vrf',
'quickjs'
] as const;
type WarpPluginPartialType = `smartweave-extension-${string}`;
export type WarpKnownPluginType = (typeof knownWarpPlugins)[number];
Expand Down
47 changes: 45 additions & 2 deletions src/core/modules/impl/HandlerExecutorFactory.ts
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ import { isBrowser } from '../../../utils/utils';
import { Buffer } from 'warp-isomorphic';
import { InteractionState } from '../../../contract/states/InteractionState';
import { WarpLogger } from '../../../logging/WarpLogger';
import { XOR } from 'utils/types/mutually-exclusive';

// 'require' to fix esbuild adding same lib in both cjs and esm format
// https://github.com/evanw/esbuild/issues/1950
Expand Down Expand Up @@ -208,6 +209,14 @@ export class HandlerExecutorFactory implements ExecutorFactory<HandlerApi<unknow
swGlobal: swGlobal,
contractDefinition
});
} else if (warp.hasPlugin('quickjs')) {
const quickJsPlugin = warp.loadPlugin<QuickJsPluginInput, HandlerApi<State>>('quickjs');
return await quickJsPlugin.process({
contractSource: contractDefinition.src,
evaluationOptions,
swGlobal: swGlobal,
contractDefinition
});
} else {
const contractFunction = new Function(normalizedSource);
const handler = isBrowser()
Expand Down Expand Up @@ -286,18 +295,37 @@ export interface HandlerApi<State> {
export type HandlerResult<State, Result> = {
result: Result;
state: State;
event: InteractionCompleteEvent;
event?: InteractionCompleteEvent;
gasUsed?: number;
};

export type InteractionResult<State, Result> = HandlerResult<State, Result> & {
type WarpInteractionResult<State, Result> = HandlerResult<State, Result> & {
type: InteractionResultType;
errorMessage?: string;
error?: unknown;
originalValidity?: Record<string, boolean>;
originalErrorMessages?: Record<string, string>;
};

export type AoInteractionResult<Result> = {
Memory: string;
Error: string;
Messages: {
target: string;
data: string;
anchor: string;
tags: { name: string; value: string }[];
}[];
Spawns: {
data: string;
anchor: string;
tags: { name: string; value: string }[];
}[];
Output: Result;
};

export type InteractionResult<State, Result> = XOR<WarpInteractionResult<State, Result>, AoInteractionResult<Result>>;

export type InteractionType = 'view' | 'write';

export type ContractInteraction<Input> = {
Expand Down Expand Up @@ -330,3 +358,18 @@ export interface VM2PluginInput {
logger: WarpLogger;
contractDefinition: ContractDefinition<unknown>;
}

export interface QuickJsPluginInput {
contractSource: string;
evaluationOptions: EvaluationOptions;
swGlobal: SmartWeaveGlobal;
contractDefinition: ContractDefinition<unknown>;
wasmMemory?: WebAssembly.Memory;
}

export interface QuickJsOptions {
memoryLimit?: number;
maxStackSize?: number;
interruptCycles?: number;
timeout?: number;
}
2 changes: 2 additions & 0 deletions src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,8 @@ export * from './contract/Signature';
export * from './contract/EvaluationOptionsEvaluator';
export * from './contract/deploy/Source';
export * from './contract/deploy/CreateContract';
export * from './contract/states/ContractInteractionState';
export * from './contract/states/InteractionState';

export * from './legacy/gqlResult';
export * from './legacy/smartweave-global';
Expand Down
2 changes: 2 additions & 0 deletions src/utils/types/mutually-exclusive.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
type Without<T, U> = { [P in Exclude<keyof T, keyof U>]?: never };
export type XOR<T, U> = T | U extends object ? (Without<T, U> & U) | (Without<U, T> & T) : T | U;

0 comments on commit e0ffd14

Please sign in to comment.