Nabarun
65001568c8
Some checks failed
Tests / sdk_tests (push) Failing after 8m38s
Refactors the `Record.Attributes` from Any into a byte string. Companion to cerc-io/laconicd#132. Resolves https://github.com/cerc-io/laconicd/issues/107 Co-authored-by: Roy Crihfield <roy@manteia.ltd> Co-authored-by: Prathamesh Musale <prathamesh.musale0@gmail.com> Reviewed-on: #52 Reviewed-by: Thomas E Lackey <telackey@noreply.git.vdb.to> Co-authored-by: Nabarun <nabarun@deepstacksoft.com> Co-committed-by: Nabarun <nabarun@deepstacksoft.com>
82 lines
2.9 KiB
TypeScript
82 lines
2.9 KiB
TypeScript
import path from 'path';
|
|
|
|
import { Registry } from './index';
|
|
import { getConfig, ensureUpdatedConfig, provisionBondId } from './testing/helper';
|
|
|
|
const WATCHER_YML_PATH = path.join(__dirname, './testing/data/watcher.yml');
|
|
|
|
jest.setTimeout(40 * 1000);
|
|
|
|
const { chainId, restEndpoint, gqlEndpoint, privateKey, fee } = getConfig();
|
|
|
|
describe('Querying', () => {
|
|
let watcher: any;
|
|
let registry: Registry;
|
|
let bondId: string;
|
|
|
|
beforeAll(async () => {
|
|
registry = new Registry(gqlEndpoint, restEndpoint, chainId);
|
|
bondId = await provisionBondId(registry, privateKey, fee);
|
|
|
|
const publishNewWatcherVersion = async () => {
|
|
watcher = await ensureUpdatedConfig(WATCHER_YML_PATH);
|
|
await registry.setRecord({ privateKey, record: watcher.record, bondId }, privateKey, fee);
|
|
return watcher.record.version;
|
|
};
|
|
|
|
await publishNewWatcherVersion();
|
|
});
|
|
|
|
test('Endpoint and chain ID.', async () => {
|
|
expect(registry.endpoints.rest).toBe(restEndpoint);
|
|
expect(registry.endpoints.gql).toBe(gqlEndpoint);
|
|
expect(registry.chainID).toBe(chainId);
|
|
});
|
|
|
|
test('Get status.', async () => {
|
|
const status = await registry.getStatus();
|
|
expect(status).toBeDefined();
|
|
expect(status.version).toBeDefined();
|
|
});
|
|
|
|
test('List records.', async () => {
|
|
const records = await registry.queryRecords({}, true);
|
|
expect(records.length).toBeGreaterThanOrEqual(1);
|
|
});
|
|
|
|
test('Query records by reference.', async () => {
|
|
const { repo_registration_record_cid } = watcher.record;
|
|
const records = await registry.queryRecords({ repo_registration_record_cid }, true);
|
|
expect(records.length).toBeGreaterThanOrEqual(1);
|
|
|
|
const { attributes: { repo_registration_record_cid: record_repo_registration_record_cid } } = records[0];
|
|
expect(repo_registration_record_cid).toStrictEqual(record_repo_registration_record_cid);
|
|
});
|
|
|
|
test('Query records by attributes.', async () => {
|
|
const { version, url } = watcher.record;
|
|
const records = await registry.queryRecords({ version, url, type: undefined }, true);
|
|
expect(records.length).toBe(1);
|
|
|
|
[ watcher ] = records;
|
|
const { attributes: { version: recordVersion, url: recordName } } = watcher;
|
|
expect(recordVersion).toBe(version);
|
|
expect(recordName).toBe(url);
|
|
});
|
|
|
|
test('Query records by id.', async () => {
|
|
const records = await registry.getRecordsByIds([watcher.id]);
|
|
expect(records.length).toBe(1);
|
|
expect(records[0].id).toBe(watcher.id);
|
|
});
|
|
|
|
test('Query records passing refs true.', async () => {
|
|
const [record] = await registry.getRecordsByIds([watcher.id], true);
|
|
expect(record.id).toBe(watcher.id);
|
|
// temp fix
|
|
expect(record.attributes.repo_registration_record_cid).toBeDefined();
|
|
expect(record.attributes.repo_registration_record_cid).toHaveProperty("/");
|
|
expect(record.attributes.repo_registration_record_cid["/"]).toHaveLength(46);
|
|
});
|
|
});
|