@efffrida/ rpc (英语)

提供效果 rpc 协议的执行(用于 effect/rpc这 通过frida脚本消息和 rpc 导出来通信。 双方都可以是 服务器 :

• @efffrida/rpc/frida 在代理内运行 : FridaRpcServer.layerProtocolFrida 财务报告和审定财务报表 FridaRpcClient.layerProtocolFrida。 。 。 .
• @efffrida/rpc/node 以节点运行并需要 FridaScript 从 @efffrida/frida-tools数字 : FridaRpcClient.layerProtocolFrida 财务报告和审定财务报表 FridaRpcServer.layerProtocolFrida。 。 。 .

双方必须使用同样的 RpcSerialization。 。 。 .

示例用途

共享的 rpc 定义, requests.ts数字 :

import * as Rpc from "effect/rpc/Rpc";
import * as RpcGroup from "effect/rpc/RpcGroup";
import * as Schema from "effect/Schema";

export class UserRpcs extends RpcGroup.make(
    Rpc.make("UserById", {
        success: Schema.Struct({ id: Schema.String, name: Schema.String }),
        error: Schema.String,
        payload: { id: Schema.String },
    })
) {}

服务器,运行在frida代理, agent.ts数字 :

import "@efffrida/polyfills";

import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as RpcSerialization from "effect/rpc/RpcSerialization";
import * as RpcServer from "effect/rpc/RpcServer";

import { FridaRuntime } from "@efffrida/platform";
import { FridaRpcServer } from "@efffrida/rpc/frida";

import { UserRpcs } from "./requests.ts";

const UsersLive = UserRpcs.toLayer({
    UserById: ({ id }) => (id === "1" ? Effect.succeed({ id, name: "Alice" }) : Effect.fail(`User not found: ${id}`)),
});

const ProtocolLive = FridaRpcServer.layerProtocolFrida().pipe(Layer.provide(RpcSerialization.layerNdjson));
const Main = RpcServer.layer(UserRpcs).pipe(Layer.provide(UsersLive), Layer.provide(ProtocolLive));

FridaRuntime.runMain(Layer.launch(Main));

客户端,在节点运行, main.ts数字 :

import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as RpcClient from "effect/rpc/RpcClient";
import * as RpcSerialization from "effect/rpc/RpcSerialization";

import * as NodeRuntime from "@effect/platform-node/NodeRuntime";
import { FridaDevice, FridaScript, FridaSession } from "@efffrida/frida-tools";
import { FridaRpcClient } from "@efffrida/rpc/node";

import { UserRpcs } from "./requests.ts";

const FridaLive = Layer.provideMerge(FridaSession.layer(["/usr/bin/sleep", "infinity"]), FridaDevice.layerLocalDevice);
const ScriptLive = FridaScript.layer(new URL("agent.ts", import.meta.url)).pipe(Layer.provide(FridaLive));

const ProtocolLive = FridaRpcClient.layerProtocolFrida().pipe(
    Layer.provide(RpcSerialization.layerNdjson),
    Layer.provide(ScriptLive)
);

const program = Effect.gen(function* () {
    const client = yield* RpcClient.make(UserRpcs);
    const user = yield* client.UserById({ id: "1" });
    yield* Effect.log(user);
}).pipe(Effect.scoped, Effect.provide(ProtocolLive));

NodeRuntime.runMain(program);

反向工作方式相同: FridaRpcServer.layerProtocolFrida 从 @efffrida/rpc/node 为 rpcs 服务 FridaRpcClient.layerProtocolFrida 从 @efffrida/rpc/frida。 。 。 .