fluencelabs/fluence-js
1
0
Fork 0
mirror of https://github.com/fluencelabs/fluence-js.git synced 2025-05-12 17:37:12 +00:00
Code Issues Projects Releases Wiki Activity

import from "xx" -> import from "xx.js"

Browse Source
This commit is contained in:
Pavel Murygin 2022-09-20 12:24:20 +03:00
parent 0dc482b479
commit cbf9028c39
32 changed files with 97 additions and 99 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
packages/fluence-connection/.prettierrc.js → packages/fluence-connection/.prettierrc.cjs
View File

2
packages/fluence-connection/src/index.ts
View File

@ -27,7 +27,7 @@ import { Multiaddr } from '@multiformats/multiaddr';
import { Connection } from '@libp2p/interface-connection';
export { Multiaddr } from '@multiformats/multiaddr';
import Buffer from './Buffer';
import Buffer from './Buffer.js';
export const PROTOCOL_NAME = '/fluence/particle/2.0.0';

0
packages/fluence-js/.prettierrc.js → packages/fluence-js/.prettierrc.cjs
View File

4
packages/fluence-js/src/__test__/_aqua/marine-js-logging.ts
View File

@ -6,8 +6,8 @@
* Aqua version: 0.7.2-314
*
*/
import { Fluence, FluencePeer } from '../../index';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3';
import { Fluence, FluencePeer } from '../../index.js';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3.js';
// Services

4
packages/fluence-js/src/__test__/_aqua/marine-js.ts
View File

@ -6,8 +6,8 @@
* Aqua version: 0.7.2-314
*
*/
import { Fluence, FluencePeer } from '../../index';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3';
import { Fluence, FluencePeer } from '../../index.js';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3.js';
// Services

4
packages/fluence-js/src/__test__/_aqua/sig-tests.ts
View File

@ -6,8 +6,8 @@
* Aqua version: 0.7.2-314
*
*/
import { Fluence, FluencePeer } from '../../index';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3';
import { Fluence, FluencePeer } from '../../index.js';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3.js';
// Services

6
packages/fluence-js/src/__test__/integration/avm.spec.ts
View File

@ -1,6 +1,6 @@
import { FluencePeer } from '../../index';
import { handleTimeout } from '../../internal/utils';
import { registerHandlersHelper } from '../util';
import { FluencePeer } from '../../index.js';
import { handleTimeout } from '../../internal/utils.js';
import { registerHandlersHelper } from '../util.js';
let peer: FluencePeer;

6
packages/fluence-js/src/__test__/integration/marine-js.spec.ts
View File

@ -1,8 +1,8 @@
import { Fluence, FluencePeer } from '../../index';
import fs from 'fs';
import path from 'path';
import { call } from '../_aqua/marine-js';
import { call_info } from '../_aqua/marine-js-logging';
import { Fluence, FluencePeer } from '../../index.js';
import { call } from '../_aqua/marine-js.js';
import { call_info } from '../_aqua/marine-js-logging.js';
describe('Marine js tests', () => {
beforeEach(async () => {

8
packages/fluence-js/src/__test__/integration/peer.spec.ts
View File

@ -1,9 +1,9 @@
import { Multiaddr } from '@fluencelabs/connection';
import { nodes } from '../connection';
import { FluencePeer } from '../../index';
import { checkConnection, doNothing, handleTimeout } from '../../internal/utils';
import { registerHandlersHelper } from '../util';
import { nodes } from '../connection.js';
import { FluencePeer } from '../../index.js';
import { checkConnection, doNothing, handleTimeout } from '../../internal/utils.js';
import { registerHandlersHelper } from '../util.js';
let peer: FluencePeer;

6
packages/fluence-js/src/__test__/integration/sigService.spec.ts
View File

@ -1,6 +1,6 @@
import { Fluence, FluencePeer, KeyPair, setLogLevel } from '../../index';
import { allowServiceFn, Sig } from '../../services';
import { registerSig, registerDataProvider, callSig } from '../_aqua/sig-tests';
import { Fluence, FluencePeer, KeyPair, setLogLevel } from '../../index.js';
import { allowServiceFn, Sig } from '../../services.js';
import { registerSig, registerDataProvider, callSig } from '../_aqua/sig-tests.js';
let peer: FluencePeer;

2
packages/fluence-js/src/__test__/unit/ast.spec.ts
View File

@ -1,4 +1,4 @@
import { Fluence } from '../../index';
import { Fluence } from '../../index.js';
describe('Parse ast tests', () => {
beforeAll(async () => {

6
packages/fluence-js/src/__test__/unit/builtInHandler.spec.ts
View File

@ -1,8 +1,8 @@
import { CallParams, CallServiceData } from '../../internal/commonTypes';
import { builtInServices } from '../../internal/builtins/common';
import { KeyPair } from '@fluencelabs/keypair';
import { Sig, defaultSigGuard, allowServiceFn } from '../../internal/builtins/Sig';
import { toUint8Array } from 'js-base64';
import { CallParams, CallServiceData } from '../../internal/commonTypes.js';
import { builtInServices } from '../../internal/builtins/common.js';
import { Sig, defaultSigGuard, allowServiceFn } from '../../internal/builtins/Sig.js';
const a10b20 = `{
"a": 10,

4
packages/fluence-js/src/__test__/unit/compiler/v2.spec.ts
View File

@ -1,5 +1,5 @@
import { Fluence, FluencePeer } from '../../..';
import { forTests } from '../../../internal/compilerSupport/v2';
import { Fluence, FluencePeer } from '../../../index.js';
import { forTests } from '../../../internal/compilerSupport/v2.js';
const peer = new FluencePeer();
const cfg = { ttl: 1000 };

2
packages/fluence-js/src/__test__/unit/compiler/v3.spec.ts
View File

@ -1,4 +1,4 @@
import { aqua2ts, ts2aqua } from '../../../internal/compilerSupport/v3impl/conversions';
import { aqua2ts, ts2aqua } from '../../../internal/compilerSupport/v3impl/conversions.js';
const i32 = { tag: 'scalar', name: 'i32' } as const;

6
packages/fluence-js/src/__test__/unit/ephemeral.spec.ts
View File

@ -1,7 +1,7 @@
import { KeyPair } from '@fluencelabs/keypair';
import { EphemeralNetwork, defaultConfig } from '../../internal/ephemeral';
import { FluencePeer } from '../../index';
import { ResultCodes } from '../../internal/commonTypes';
import { EphemeralNetwork, defaultConfig } from '../../internal/ephemeral.js';
import { FluencePeer } from '../../index.js';
import { ResultCodes } from '../../internal/commonTypes.js';
let en: EphemeralNetwork;
let peer: FluencePeer;

6
packages/fluence-js/src/__test__/util.ts
View File

@ -1,6 +1,6 @@
import { FluencePeer } from '../index';
import { Particle } from '../internal/Particle';
import { MakeServiceCall } from '../internal/utils';
import { FluencePeer } from '../index.js';
import { Particle } from '../internal/Particle.js';
import { MakeServiceCall } from '../internal/utils.js';
export const registerHandlersHelper = (
peer: FluencePeer,

14
packages/fluence-js/src/index.ts
View File

@ -16,15 +16,15 @@
import log, { LogLevelDesc } from 'loglevel';
export { KeyPair } from '@fluencelabs/keypair';
import { FluencePeer, PeerConfig } from './internal/FluencePeer';
export { PeerStatus } from './internal/FluencePeer';
export { FluencePeer, PeerConfig } from './internal/FluencePeer';
export { MarineLoglevel as AvmLoglevel } from './internal/utils';
export { PeerIdB58, CallParams } from './internal/commonTypes';
export { loadWasmFromFileSystem, loadWasmFromNpmPackage, loadWasmFromServer } from '@fluencelabs/marine-js';
import { FluencePeer, PeerConfig } from './internal/FluencePeer.js';
export { PeerStatus } from './internal/FluencePeer.js';
export { FluencePeer, PeerConfig } from './internal/FluencePeer.js';
export { MarineLoglevel as AvmLoglevel } from './internal/utils.js';
export { PeerIdB58, CallParams } from './internal/commonTypes.js';
export const setLogLevel = (level: LogLevelDesc) => {
log.setLevel(level);
};

21
packages/fluence-js/src/internal/FluencePeer.ts
View File

@ -16,21 +16,20 @@
import { RelayConnection, Multiaddr } from '@fluencelabs/connection';
import { FluenceConnection } from '@fluencelabs/interfaces';
import { KeyPair } from '@fluencelabs/keypair';
import { FluenceAppService, loadDefaults, loadWasmFromFileSystem, loadWasmFromServer } from '@fluencelabs/marine-js';
import type { MultiaddrInput } from '@multiformats/multiaddr';
import { CallServiceData, CallServiceResult, GenericCallServiceHandler, ResultCodes } from './commonTypes';
import { PeerIdB58 } from './commonTypes';
import { Particle, ParticleExecutionStage, ParticleQueueItem } from './Particle';
import { throwIfNotSupported, dataToString, jsonify, MarineLoglevel, marineLogLevelToEnvs, isString } from './utils';
import { concatMap, filter, pipe, Subject, tap } from 'rxjs';
import log from 'loglevel';
import { builtInServices } from './builtins/common';
import { defaultSigGuard, Sig } from './builtins/Sig';
import { registerSig } from './_aqua/services';
import Buffer from './Buffer';
import { isBrowser, isNode } from 'browser-or-node';
import { deserializeAvmResult, InterpreterResult, JSONValue, LogLevel, serializeAvmArgs } from '@fluencelabs/avm';
import { concatMap, filter, pipe, Subject, tap } from 'rxjs';
import { FluenceAppService, loadDefaults, loadWasmFromFileSystem, loadWasmFromServer } from '@fluencelabs/marine-js';
import { PeerIdB58, CallServiceData, CallServiceResult, GenericCallServiceHandler, ResultCodes } from './commonTypes.js';
import { Particle, ParticleExecutionStage, ParticleQueueItem } from './Particle.js';
import { throwIfNotSupported, dataToString, jsonify, MarineLoglevel, marineLogLevelToEnvs, isString } from './utils.js';
import { builtInServices } from './builtins/common.js';
import { defaultSigGuard, Sig } from './builtins/Sig.js';
import { registerSig } from './_aqua/services.js';
import Buffer from './Buffer.js';
/**
* Node of the Fluence network specified as a pair of node's multiaddr and it's peer id

8
packages/fluence-js/src/internal/Particle.ts
View File

@ -13,15 +13,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import 'buffer';
import { CallResultsArray, LogLevel } from '@fluencelabs/avm';
import { v4 as uuidv4 } from 'uuid';
import { fromByteArray, toByteArray } from 'base64-js';
import log from 'loglevel';
import { ParticleContext } from './commonTypes';
import { dataToString, jsonify } from './utils';
import Buffer from './Buffer';
import { ParticleContext } from './commonTypes.js';
import { dataToString, jsonify } from './utils.js';
import Buffer from './Buffer.js';
export class Particle {
// TODO: make it not optional (should be added to the constructor)

4
packages/fluence-js/src/internal/_aqua/services.ts
View File

@ -6,8 +6,8 @@
* Aqua version: 0.7.2-314
*
*/
import { Fluence, FluencePeer } from '../../index';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3';
import { Fluence, FluencePeer } from '../../index.js';
import { CallParams, callFunction, registerService } from '../../internal/compilerSupport/v3.js';
// Services

5
packages/fluence-js/src/internal/builtins/Sig.ts
View File

@ -1,7 +1,8 @@
import { SecurityTetraplet } from '@fluencelabs/avm';
import { CallParams, PeerIdB58 } from '../commonTypes';
import { KeyPair } from '@fluencelabs/keypair';
import { SigDef } from '../_aqua/services';
import { CallParams, PeerIdB58 } from '../commonTypes.js';
import { SigDef } from '../_aqua/services.js';
/**
* A predicate of call params for sig service's sign method which determines whether signing operation is allowed or not

6
packages/fluence-js/src/internal/builtins/common.ts
View File

@ -18,9 +18,9 @@ import bs58 from 'bs58';
import { sha256 } from 'multiformats/hashes/sha2';
import { CallServiceResult } from '@fluencelabs/avm';
import { GenericCallServiceHandler, ResultCodes } from '../commonTypes';
import { jsonify } from '../utils';
import Buffer from '../Buffer';
import { GenericCallServiceHandler, ResultCodes } from '../commonTypes.js';
import { jsonify } from '../utils.js';
import Buffer from '../Buffer.js';
const success = (result: any): CallServiceResult => {
return {

10
packages/fluence-js/src/internal/compilerSupport/v2.ts
View File

@ -16,12 +16,12 @@
import { SecurityTetraplet } from '@fluencelabs/avm';
import { match } from 'ts-pattern';
import { CallParams, Fluence, FluencePeer } from '../../index';
import { CallServiceData, GenericCallServiceHandler, CallServiceResult, ResultCodes } from '../commonTypes';
import { Particle } from '../Particle';
import { CallParams, Fluence, FluencePeer } from '../../index.js';
import type { CallServiceData, CallServiceResult } from '../commonTypes';
import { ResultCodes } from '../commonTypes';
export { FluencePeer } from '../FluencePeer';
export { CallParams } from '../commonTypes';
export { FluencePeer } from '../FluencePeer.js';
export { CallParams } from '../commonTypes.js';
/**
* Represents the Aqua Option type

10
packages/fluence-js/src/internal/compilerSupport/v3.ts
View File

@ -14,8 +14,8 @@
* limitations under the License.
*/
export { FluencePeer } from '../FluencePeer';
export { CallParams } from '../commonTypes';
export * from './v3impl/interface';
export * from './v3impl/callFunction';
export * from './v3impl/registerService';
export { FluencePeer } from '../FluencePeer.js';
export { CallParams } from '../commonTypes.js';
export * from './v3impl/interface.js';
export * from './v3impl/callFunction.js';
export * from './v3impl/registerService.js';

10
packages/fluence-js/src/internal/compilerSupport/v3impl/callFunction.ts
View File

@ -1,7 +1,7 @@
import { FnConfig, FunctionCallDef } from './interface';
import { FluencePeer } from '../../FluencePeer';
import { Fluence } from '../../../index';
import { Particle } from '../../Particle';
import { FnConfig, FunctionCallDef } from './interface.js';
import { FluencePeer } from '../../FluencePeer.js';
import { Fluence } from '../../../index.js';
import {
injectRelayService,
argToServiceDef,
@ -11,7 +11,7 @@ import {
ServiceDescription,
userHandlerService,
injectValueService,
} from './services';
} from './services.js';
/**
* Convenience function to support Aqua `func` generation backend

6
packages/fluence-js/src/internal/compilerSupport/v3impl/conversions.ts
View File

@ -1,7 +1,7 @@
import { jsonify } from '../../utils';
import { match } from 'ts-pattern';
import { ArrowType, ArrowWithoutCallbacks, NonArrowType, UnlabeledProductType } from './interface';
import { CallServiceData } from 'src/internal/commonTypes';
import { jsonify } from '../../utils.js';
import { ArrowType, ArrowWithoutCallbacks, NonArrowType, UnlabeledProductType } from './interface.js';
import { CallServiceData } from 'src/internal/commonTypes.js';
/**
* Convert value from its representation in aqua language to representation in typescript

8
packages/fluence-js/src/internal/compilerSupport/v3impl/registerService.ts
View File

@ -1,7 +1,7 @@
import { FluencePeer } from '../../FluencePeer';
import { Fluence } from '../../../index';
import { ServiceDef } from './interface';
import { registerGlobalService, userHandlerService } from './services';
import { FluencePeer } from '../../FluencePeer.js';
import { Fluence } from '../../../index.js';
import { ServiceDef } from './interface.js';
import { registerGlobalService, userHandlerService } from './services.js';
/**
* Convenience function to support Aqua `service` generation backend

10
packages/fluence-js/src/internal/compilerSupport/v3impl/services.ts
View File

@ -1,12 +1,12 @@
import { SecurityTetraplet } from '@fluencelabs/avm';
import { match } from 'ts-pattern';
import { Particle } from '../../Particle';
import { CallParams, CallServiceData, GenericCallServiceHandler, ResultCodes } from '../../commonTypes';
import { FluencePeer } from '../../FluencePeer';
import { Particle } from '../../Particle.js';
import { CallParams, CallServiceData, GenericCallServiceHandler, ResultCodes } from '../../commonTypes.js';
import { FluencePeer } from '../../FluencePeer.js';
import { aquaArgs2Ts, responseServiceValue2ts, returnType2Aqua, ts2aqua } from './conversions';
import { ArrowWithoutCallbacks, FunctionCallConstants, FunctionCallDef, NonArrowType } from './interface';
import { aquaArgs2Ts, responseServiceValue2ts, returnType2Aqua, ts2aqua } from './conversions.js';
import { ArrowWithoutCallbacks, FunctionCallConstants, FunctionCallDef, NonArrowType } from './interface.js';
export interface ServiceDescription {
serviceId: string;

6
packages/fluence-js/src/internal/ephemeral.ts
View File

@ -1,10 +1,10 @@
import { FluenceConnection, ParticleHandler } from '@fluencelabs/interfaces';
import { keyPairFromBase64Sk } from '@fluencelabs/keypair';
import { PeerIdB58 } from './commonTypes';
import { FluencePeer } from '../index';
import log from 'loglevel';
import { PeerIdB58 } from './commonTypes.js';
import { FluencePeer } from '../index.js';
interface EphemeralConfig {
peers: Array<{
peerId: PeerIdB58;

8
packages/fluence-js/src/internal/utils.ts
View File

@ -19,10 +19,10 @@ import log from 'loglevel';
import platform from 'platform';
import { LogLevel } from '@fluencelabs/avm';
import { CallServiceData, CallServiceResult, CallServiceResultType, ResultCodes } from './commonTypes';
import { FluencePeer } from './FluencePeer';
import { ParticleExecutionStage } from './Particle';
import Buffer from './Buffer';
import { CallServiceData, CallServiceResult, CallServiceResultType, ResultCodes } from './commonTypes.js';
import { FluencePeer } from './FluencePeer.js';
import { ParticleExecutionStage } from './Particle.js';
import Buffer from './Buffer.js';
export const MakeServiceCall =
(fn: (args: any[]) => CallServiceResultType) =>

4
packages/fluence-js/src/services.ts
View File

@ -1,2 +1,2 @@
export * from './internal/builtins/Sig';
export { registerSig } from './internal/_aqua/services';
export * from './internal/builtins/Sig.js';
export { registerSig } from './internal/_aqua/services.js';

0
packages/fluence-keypair/.prettierrc.js → packages/fluence-keypair/.prettierrc.cjs
View File