One Hat Cyber Team

Your IP: 216.73.217.4
Server IP: 41.128.143.86
Server: Linux host.raqmix.cloud 6.8.0-1025-azure #30~22.04.1-Ubuntu SMP Wed Mar 12 15:28:20 UTC 2025 x86_64
Server Software: Apache
PHP Version: 8.3.23
Buat File | Buat Folder

Dir : ~/usr/share/grafana/public/test/mocks/

Edit File: datasource_srv.ts

import { Observable } from 'rxjs';

import {
  DataQueryRequest,
  DataQueryResponse,
  TestDataSourceResponse,
  DataSourceApi,
  DataSourceInstanceSettings,
  DataSourcePluginMeta,
  DataSourceRef,
  getDataSourceUID,
} from '@grafana/data';

export class DatasourceSrvMock {
  constructor(
    private defaultDS: DataSourceApi,
    private datasources: { [name: string]: DataSourceApi }
  ) {
    //
  }

get(ref?: DataSourceRef | string): Promise<DataSourceApi> {
    if (!ref) {
      return Promise.resolve(this.defaultDS);
    }
    const uid = getDataSourceUID(ref) ?? '';
    const ds = this.datasources[uid];
    if (ds) {
      return Promise.resolve(ds);
    }
    return Promise.reject(`Unknown Datasource: ${JSON.stringify(ref)}`);
  }
}

export class MockDataSourceApi extends DataSourceApi {
  result: DataQueryResponse = { data: [] };

constructor(
    datasource: string | DataSourceInstanceSettings = 'MockDataSourceApi',
    result?: DataQueryResponse,
    meta?: DataSourcePluginMeta,
    public error: string | null = null
  ) {
    const instaceSettings =
      typeof datasource === 'string' ? ({ name: datasource } as DataSourceInstanceSettings) : datasource;
    super(instaceSettings);
    if (result) {
      this.result = result;
    }

this.meta = meta || ({} as DataSourcePluginMeta);
  }

query(request: DataQueryRequest): Promise<DataQueryResponse> | Observable<DataQueryResponse> {
    if (this.error) {
      return Promise.reject(this.error);
    }

return new Promise((resolver) => {
      setTimeout(() => {
        resolver(this.result);
      });
    });
  }

testDatasource(): Promise<TestDataSourceResponse> {
    return Promise.resolve({ message: '', status: '' });
  }

setupMixed(value: boolean) {
    this.meta = this.meta || {};
    this.meta.mixed = value;
    return this;
  }
}

export class MockObservableDataSourceApi extends DataSourceApi {
  results: DataQueryResponse[] = [{ data: [] }];

constructor(
    name?: string,
    results?: DataQueryResponse[],
    meta?: DataSourcePluginMeta,
    private error: string | null = null
  ) {
    super({ name: name ? name : 'MockDataSourceApi' } as DataSourceInstanceSettings);

if (results) {
      this.results = results;
    }

this.meta = meta || ({} as DataSourcePluginMeta);
  }

query(request: DataQueryRequest): Observable<DataQueryResponse> {
    return new Observable((observer) => {
      if (this.error) {
        observer.error(this.error);
      }

if (this.results) {
        this.results.forEach((response) => observer.next(response));
        observer.complete();
      }
    });
  }

testDatasource(): Promise<TestDataSourceResponse> {
    return Promise.resolve({ message: '', status: '' });
  }
}