diff --git a/packages/cactus-plugin-ledger-connector-besu/src/main/json/openapi.json b/packages/cactus-plugin-ledger-connector-besu/src/main/json/openapi.json
index ef5717d640d..5369865a733 100644
--- a/packages/cactus-plugin-ledger-connector-besu/src/main/json/openapi.json
+++ b/packages/cactus-plugin-ledger-connector-besu/src/main/json/openapi.json
@@ -876,6 +876,41 @@
                 }
             }
         },
+        "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-besu/get-past-logs": {
+            "post": {
+                "x-hyperledger-cactus": {
+                    "http": {
+                        "verbLowerCase": "post",
+                        "path": "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-besu/get-past-logs"
+                    }
+                },
+                "operationId": "getPastLogsV1",
+                "summary": "Gets past logs, matching the given options.",
+                "parameters": [],
+                "requestBody": {
+                    "content": {
+                        "application/json": {
+                            "schema": {
+                                "$ref": "#/components/schemas/GetPastLogsV1Request"
+                            }
+                        }
+                        
+                    }
+                },
+                "responses": {
+                    "200": {
+                        "description": "OK",
+                        "content": {
+                            "application/json": {
+                                "schema": {
+                                    "$ref": "#/components/schemas/GetPastLogsV1Response"
+                                }
+                            }
+                        }
+                    }
+                }
+            }
+        },
         "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-besu/invoke-contract": {
             "post": {
                 "x-hyperledger-cactus": {
diff --git a/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/generated/openapi/typescript-axios/api.ts b/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/generated/openapi/typescript-axios/api.ts
index 16b9400ecd5..173b2d0a813 100644
--- a/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/generated/openapi/typescript-axios/api.ts
+++ b/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/generated/openapi/typescript-axios/api.ts
@@ -925,6 +925,40 @@ export const DefaultApiAxiosParamCreator = function (configuration?: Configurati
                 options: localVarRequestOptions,
             };
         },
+        /**
+         * 
+         * @summary Gets past logs, matching the given options.
+         * @param {GetPastLogsV1Request} [getPastLogsV1Request] 
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        getPastLogsV1: async (getPastLogsV1Request?: GetPastLogsV1Request, options: any = {}): Promise<RequestArgs> => {
+            const localVarPath = `/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-besu/get-past-logs`;
+            // use dummy base URL string because the URL constructor only accepts absolute URLs.
+            const localVarUrlObj = new URL(localVarPath, DUMMY_BASE_URL);
+            let baseOptions;
+            if (configuration) {
+                baseOptions = configuration.baseOptions;
+            }
+
+            const localVarRequestOptions = { method: 'POST', ...baseOptions, ...options};
+            const localVarHeaderParameter = {} as any;
+            const localVarQueryParameter = {} as any;
+
+
+    
+            localVarHeaderParameter['Content-Type'] = 'application/json';
+
+            setSearchParams(localVarUrlObj, localVarQueryParameter, options.query);
+            let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
+            localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};
+            localVarRequestOptions.data = serializeDataIfNeeded(getPastLogsV1Request, localVarRequestOptions, configuration)
+
+            return {
+                url: toPathString(localVarUrlObj),
+                options: localVarRequestOptions,
+            };
+        },
         /**
          * 
          * @summary Get the Prometheus Metrics
@@ -1034,6 +1068,17 @@ export const DefaultApiFp = function(configuration?: Configuration) {
             const localVarAxiosArgs = await localVarAxiosParamCreator.apiV1BesuRunTransaction(runTransactionRequest, options);
             return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);
         },
+        /**
+         * 
+         * @summary Gets past logs, matching the given options.
+         * @param {GetPastLogsV1Request} [getPastLogsV1Request] 
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        async getPastLogsV1(getPastLogsV1Request?: GetPastLogsV1Request, options?: any): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<GetPastLogsV1Response>> {
+            const localVarAxiosArgs = await localVarAxiosParamCreator.getPastLogsV1(getPastLogsV1Request, options);
+            return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);
+        },
         /**
          * 
          * @summary Get the Prometheus Metrics
@@ -1095,6 +1140,16 @@ export const DefaultApiFactory = function (configuration?: Configuration, basePa
         apiV1BesuRunTransaction(runTransactionRequest?: RunTransactionRequest, options?: any): AxiosPromise<RunTransactionResponse> {
             return localVarFp.apiV1BesuRunTransaction(runTransactionRequest, options).then((request) => request(axios, basePath));
         },
+        /**
+         * 
+         * @summary Gets past logs, matching the given options.
+         * @param {GetPastLogsV1Request} [getPastLogsV1Request] 
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        getPastLogsV1(getPastLogsV1Request?: GetPastLogsV1Request, options?: any): AxiosPromise<GetPastLogsV1Response> {
+            return localVarFp.getPastLogsV1(getPastLogsV1Request, options).then((request) => request(axios, basePath));
+        },
         /**
          * 
          * @summary Get the Prometheus Metrics
@@ -1160,6 +1215,18 @@ export class DefaultApi extends BaseAPI {
         return DefaultApiFp(this.configuration).apiV1BesuRunTransaction(runTransactionRequest, options).then((request) => request(this.axios, this.basePath));
     }
 
+    /**
+     * 
+     * @summary Gets past logs, matching the given options.
+     * @param {GetPastLogsV1Request} [getPastLogsV1Request] 
+     * @param {*} [options] Override http request option.
+     * @throws {RequiredError}
+     * @memberof DefaultApi
+     */
+    public getPastLogsV1(getPastLogsV1Request?: GetPastLogsV1Request, options?: any) {
+        return DefaultApiFp(this.configuration).getPastLogsV1(getPastLogsV1Request, options).then((request) => request(this.axios, this.basePath));
+    }
+
     /**
      * 
      * @summary Get the Prometheus Metrics
diff --git a/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/plugin-ledger-connector-besu.ts b/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/plugin-ledger-connector-besu.ts
index 1164a430e6d..43aca593136 100644
--- a/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/plugin-ledger-connector-besu.ts
+++ b/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/plugin-ledger-connector-besu.ts
@@ -12,7 +12,10 @@ import { AbiItem } from "web3-utils";
 import { Contract, ContractSendMethod } from "web3-eth-contract";
 import { TransactionReceipt } from "web3-eth";
 
-import { GetPastLogsV1Request, GetPastLogsV1Response } from "./generated/openapi/typescript-axios/index";
+import {
+  GetPastLogsV1Request,
+  GetPastLogsV1Response,
+} from "./generated/openapi/typescript-axios/index";
 import {
   ConsensusAlgorithmFamily,
   IPluginLedgerConnector,
@@ -69,6 +72,7 @@ import {
   IGetPrometheusExporterMetricsEndpointV1Options,
 } from "./web-services/get-prometheus-exporter-metrics-endpoint-v1";
 import { WatchBlocksV1Endpoint } from "./web-services/watch-blocks-v1-endpoint";
+import { GetPastLogsEndpoint } from "./web-services/get-past-logs-endpoint";
 
 export const E_KEYCHAIN_NOT_FOUND = "cactus.connector.besu.keychain_not_found";
 
@@ -207,6 +211,13 @@ export class PluginLedgerConnectorBesu
       });
       endpoints.push(endpoint);
     }
+    {
+      const endpoint = new GetPastLogsEndpoint({
+        connector: this,
+        logLevel: this.options.logLevel,
+      });
+      endpoints.push(endpoint);
+    }
     {
       const endpoint = new RunTransactionEndpoint({
         connector: this,
@@ -706,11 +717,10 @@ export class PluginLedgerConnectorBesu
     return Optional.empty();
   }
 
-
-  public async getPastLogs(request: GetPastLogsV1Request): Promise<GetPastLogsV1Response> {
-    const logs = await this.web3.eth.getPastLogs(
-      request
-    );
-    return {logs};
+  public async getPastLogs(
+    request: GetPastLogsV1Request,
+  ): Promise<GetPastLogsV1Response> {
+    const logs = await this.web3.eth.getPastLogs(request);
+    return { logs };
   }
-}
\ No newline at end of file
+}
diff --git a/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/web-services/get-past-logs-endpoint.ts b/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/web-services/get-past-logs-endpoint.ts
new file mode 100644
index 00000000000..509e6a866cb
--- /dev/null
+++ b/packages/cactus-plugin-ledger-connector-besu/src/main/typescript/web-services/get-past-logs-endpoint.ts
@@ -0,0 +1,101 @@
+import { Express, Request, Response } from "express";
+
+import {
+  Logger,
+  Checks,
+  LogLevelDesc,
+  LoggerProvider,
+  IAsyncProvider,
+} from "@hyperledger/cactus-common";
+import {
+  IEndpointAuthzOptions,
+  IExpressRequestHandler,
+  IWebServiceEndpoint,
+} from "@hyperledger/cactus-core-api";
+import { registerWebServiceEndpoint } from "@hyperledger/cactus-core";
+
+import { PluginLedgerConnectorBesu } from "../plugin-ledger-connector-besu";
+
+import OAS from "../../json/openapi.json";
+
+export interface IGetPastLogsEndpointOptions {
+  logLevel?: LogLevelDesc;
+  connector: PluginLedgerConnectorBesu;
+}
+
+export class GetPastLogsEndpoint implements IWebServiceEndpoint {
+  public static readonly CLASS_NAME = "GetPastLogsEndpoint";
+
+  private readonly log: Logger;
+
+  public get className(): string {
+    return GetPastLogsEndpoint.CLASS_NAME;
+  }
+
+  constructor(public readonly options: IGetPastLogsEndpointOptions) {
+    const fnTag = `${this.className}#constructor()`;
+    Checks.truthy(options, `${fnTag} arg options`);
+    Checks.truthy(options.connector, `${fnTag} arg options.connector`);
+
+    const level = this.options.logLevel || "INFO";
+    const label = this.className;
+    this.log = LoggerProvider.getOrCreate({ level, label });
+  }
+
+  public getOasPath() {
+    return OAS.paths[
+      "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-besu/get-past-logs"
+    ];
+  }
+
+  public getPath(): string {
+    const apiPath = this.getOasPath();
+    return apiPath.post["x-hyperledger-cactus"].http.path;
+  }
+
+  public getVerbLowerCase(): string {
+    const apiPath = this.getOasPath();
+    return apiPath.post["x-hyperledger-cactus"].http.verbLowerCase;
+  }
+
+  public getOperationId(): string {
+    return this.getOasPath().post.operationId;
+  }
+
+  getAuthorizationOptionsProvider(): IAsyncProvider<IEndpointAuthzOptions> {
+    // TODO: make this an injectable dependency in the constructor
+    return {
+      get: async () => ({
+        isProtected: true,
+        requiredRoles: [],
+      }),
+    };
+  }
+
+  public async registerExpress(
+    expressApp: Express,
+  ): Promise<IWebServiceEndpoint> {
+    await registerWebServiceEndpoint(expressApp, this);
+    return this;
+  }
+
+  public getExpressRequestHandler(): IExpressRequestHandler {
+    return this.handleRequest.bind(this);
+  }
+
+  public async handleRequest(req: Request, res: Response): Promise<void> {
+    const reqTag = `${this.getVerbLowerCase()} - ${this.getPath()}`;
+    this.log.debug(reqTag);
+    const reqBody = req.body;
+    try {
+      const resBody = await this.options.connector.getPastLogs(reqBody);
+      res.json(resBody);
+    } catch (ex) {
+      this.log.error(`Crash while serving ${reqTag}`, ex);
+      res.status(500).json({
+        message: "Internal Server Error",
+        error: ex?.stack || ex?.message,
+      });
+    }
+  }
+}
diff --git a/packages/cactus-plugin-ledger-connector-besu/src/test/typescript/integration/plugin-ledger-connector-besu/deploy-contract/get-past-logs.test.ts b/packages/cactus-plugin-ledger-connector-besu/src/test/typescript/integration/plugin-ledger-connector-besu/deploy-contract/get-past-logs.test.ts
index c084f65df5b..d8b80b48ee3 100644
--- a/packages/cactus-plugin-ledger-connector-besu/src/test/typescript/integration/plugin-ledger-connector-besu/deploy-contract/get-past-logs.test.ts
+++ b/packages/cactus-plugin-ledger-connector-besu/src/test/typescript/integration/plugin-ledger-connector-besu/deploy-contract/get-past-logs.test.ts
@@ -62,8 +62,7 @@ test("can get past logs of an account", async (t: Test) => {
     pluginRegistry: new PluginRegistry({ plugins: [keychainPlugin] }),
   });
 
-  
-  const req: GetPastLogsV1Request = {address: firstHighNetWorthAccount,}
+  const req: GetPastLogsV1Request = { address: firstHighNetWorthAccount };
   const pastLogs = await connector.getPastLogs(req);
   t.comment(JSON.stringify(pastLogs));
   t.ok(pastLogs, "Past logs response is OK :-)");
diff --git a/packages/cactus-test-plugin-ledger-connector-besu/src/test/typescript/integration/plugin-validator-besu/get-past-logs-endpoint.test.ts b/packages/cactus-test-plugin-ledger-connector-besu/src/test/typescript/integration/plugin-validator-besu/get-past-logs-endpoint.test.ts
new file mode 100644
index 00000000000..cd080ee85a0
--- /dev/null
+++ b/packages/cactus-test-plugin-ledger-connector-besu/src/test/typescript/integration/plugin-validator-besu/get-past-logs-endpoint.test.ts
@@ -0,0 +1,171 @@
+import test, { Test } from "tape-promise/tape";
+
+import { v4 as uuidv4 } from "uuid";
+import { createServer } from "http";
+import KeyEncoder from "key-encoder";
+import { AddressInfo } from "net";
+import Web3 from "web3";
+import EEAClient, { IWeb3InstanceExtended } from "web3-eea";
+
+import {
+  ApiServer,
+  AuthorizationProtocol,
+  ConfigService,
+} from "@hyperledger/cactus-cmd-api-server";
+import {
+  Secp256k1Keys,
+  KeyFormat,
+  LogLevelDesc,
+} from "@hyperledger/cactus-common";
+
+import {
+  BesuTestLedger,
+  pruneDockerAllIfGithubAction,
+} from "@hyperledger/cactus-test-tooling";
+
+import {
+  BesuApiClientOptions,
+  BesuApiClient,
+  IPluginLedgerConnectorBesuOptions,
+  PluginLedgerConnectorBesu,
+  GetPastLogsV1Request,
+} from "@hyperledger/cactus-plugin-ledger-connector-besu";
+
+import { PluginRegistry } from "@hyperledger/cactus-core";
+
+import { PluginKeychainMemory } from "@hyperledger/cactus-plugin-keychain-memory";
+
+const testCase = "API client can call getPastLogs via network";
+const logLevel: LogLevelDesc = "TRACE";
+
+test("BEFORE " + testCase, async (t: Test) => {
+  const pruning = pruneDockerAllIfGithubAction({ logLevel });
+  await t.doesNotReject(pruning, "Pruning didn't throw OK");
+  t.end();
+});
+
+test(testCase, async (t: Test) => {
+  const keyEncoder: KeyEncoder = new KeyEncoder("secp256k1");
+  const keychainId = uuidv4();
+  const keychainRef = uuidv4();
+
+  const { privateKey } = Secp256k1Keys.generateKeyPairsBuffer();
+  const keyHex = privateKey.toString("hex");
+  const pem = keyEncoder.encodePrivate(keyHex, KeyFormat.Raw, KeyFormat.PEM);
+
+  const keychain = new PluginKeychainMemory({
+    backend: new Map([[keychainRef, pem]]),
+    keychainId,
+    logLevel,
+    instanceId: uuidv4(),
+  });
+
+  const httpServer1 = createServer();
+  await new Promise((resolve, reject) => {
+    httpServer1.once("error", reject);
+    httpServer1.once("listening", resolve);
+    httpServer1.listen(0, "127.0.0.1");
+  });
+  const addressInfo1 = httpServer1.address() as AddressInfo;
+  t.comment(`HttpServer1 AddressInfo: ${JSON.stringify(addressInfo1)}`);
+  const node1Host = `http://${addressInfo1.address}:${addressInfo1.port}`;
+  t.comment(`Cactus Node 1 Host: ${node1Host}`);
+
+  const besuTestLedger = new BesuTestLedger();
+  await besuTestLedger.start();
+
+  const tearDown = async () => {
+    await besuTestLedger.stop();
+    await besuTestLedger.destroy();
+  };
+
+  test.onFinish(tearDown);
+  const testAccount = await besuTestLedger.createEthTestAccount();
+  const rpcApiHttpHost = await besuTestLedger.getRpcApiHttpHost();
+  const rpcApiWsHost = await besuTestLedger.getRpcApiWsHost();
+
+  // 2. Instantiate plugin registry which will provide the web service plugin with the key value storage plugin
+  const pluginRegistry = new PluginRegistry({ plugins: [keychain] });
+
+  // 3. Instantiate the web service consortium plugin
+  const options: IPluginLedgerConnectorBesuOptions = {
+    instanceId: uuidv4(),
+    rpcApiHttpHost,
+    rpcApiWsHost,
+    pluginRegistry,
+    logLevel,
+  };
+  const pluginValidatorBesu = new PluginLedgerConnectorBesu(options);
+
+  // 4. Create the API Server object that we embed in this test
+  const configService = new ConfigService();
+  const apiServerOptions = configService.newExampleConfig();
+  apiServerOptions.authorizationProtocol = AuthorizationProtocol.NONE;
+  apiServerOptions.configFile = "";
+  apiServerOptions.apiCorsDomainCsv = "*";
+  apiServerOptions.apiPort = addressInfo1.port;
+  apiServerOptions.cockpitPort = 0;
+  apiServerOptions.apiTlsEnabled = false;
+  const config = configService.newExampleConfigConvict(apiServerOptions);
+
+  pluginRegistry.add(pluginValidatorBesu);
+
+  const apiServer = new ApiServer({
+    httpServerApi: httpServer1,
+    config: config.getProperties(),
+    pluginRegistry,
+  });
+
+  // 5. make sure the API server is shut down when the testing if finished.
+  test.onFinish(() => apiServer.shutdown());
+
+  // 6. Start the API server which is now listening on port A and it's healthcheck works through the main SDK
+  await apiServer.start();
+
+  // 7. Instantiate the main SDK dynamically with whatever port the API server ended up bound to (port 0)
+  t.comment(`AddressInfo: ${JSON.stringify(addressInfo1)}`);
+
+  const web3Provider = new Web3.providers.HttpProvider(rpcApiHttpHost);
+  const web3 = new Web3(web3Provider);
+  const web3Eea: IWeb3InstanceExtended = EEAClient(web3, 2018);
+
+  const orionKeyPair = await besuTestLedger.getOrionKeyPair();
+  const besuKeyPair = await besuTestLedger.getBesuKeyPair();
+
+  const besuPrivateKey = besuKeyPair.privateKey.toLowerCase().startsWith("0x")
+    ? besuKeyPair.privateKey.substring(2)
+    : besuKeyPair.privateKey; // besu node's private key
+
+  const contractOptions = {
+    data: `0x123`,
+    // privateFrom : Orion public key of the sender.
+    privateFrom: orionKeyPair.publicKey,
+    // privateFor : Orion public keys of recipients or privacyGroupId: Privacy group to receive the transaction
+    privateFor: [orionKeyPair.publicKey],
+    // privateKey: Ethereum private key with which to sign the transaction.
+    privateKey: besuPrivateKey,
+  };
+
+  const transactionHash = await web3Eea.eea.sendRawTransaction(contractOptions);
+
+  await web3.eth.getTransaction(transactionHash);
+
+  const request: GetPastLogsV1Request = {
+    address: testAccount.address,
+  };
+
+  const configuration = new BesuApiClientOptions({ basePath: node1Host });
+  const api = new BesuApiClient(configuration);
+
+  const res = await api.getPastLogsV1(request);
+  // const { } = res;
+  t.ok(res, "API response object is truthy");
+  t.ok(res.data.logs, "Response.logs is truthy ok");
+  t.true(Array.isArray(res.data.logs), "Response.logs is Array ok");
+});
+
+test("AFTER " + testCase, async (t: Test) => {
+  const pruning = pruneDockerAllIfGithubAction({ logLevel });
+  await t.doesNotReject(pruning, "Pruning didn't throw OK");
+  t.end();
+});