diff --git a/app/lib/dal/fileDAL.ts b/app/lib/dal/fileDAL.ts
index 7929b72b4acfe25bbb1cfdd201debc08f61f123c..585e0d2a683271014a1ed45ad164e5e6125143db 100644
--- a/app/lib/dal/fileDAL.ts
+++ b/app/lib/dal/fileDAL.ts
@@ -434,8 +434,10 @@ export class FileDAL implements ServerDAO {
}
async getAvailableSourcesByPubkey(pubkey: string): Promise<HttpSource[]> {
- const txAvailable = await this.sindexDAL.getAvailableForPubkey(pubkey);
- const sources: UDSource[] = await this.dividendDAL.getUDSources(pubkey);
+ const [txAvailable, sources] = await Promise.all([
+ this.sindexDAL.getAvailableForPubkey(pubkey),
+ this.dividendDAL.getUDSources(pubkey),
+ ]);
return sources
.map((d) => {
return {
@@ -705,6 +707,17 @@ export class FileDAL implements ServerDAO {
return await this.iindexDAL.getFromPubkeyOrUid(search);
}
+ async getWrittenIdtyByPubkeyForHashingAndIsMember(
+ pub: string
+ ): Promise<{
+ uid: string;
+ created_on: string;
+ pub: string;
+ member: boolean;
+ } | null> {
+ return await this.iindexDAL.getFromPubkey(pub);
+ }
+
async getWrittenIdtyByPubkeyForRevocationCheck(
pubkey: string
): Promise<{
@@ -864,8 +877,32 @@ export class FileDAL implements ServerDAO {
return i;
})
);
+ return this.fillIdentitiesRevocation(found);
+ }
+
+ async searchJustIdentitiesByPubkey(pubkey: string): Promise<DBIdentity[]> {
+ const pendings = await this.idtyDAL.findByPub(pubkey);
+ const writtenIdty = await this.iindexDAL.getOldFromPubkey(pubkey);
+ const nonPendings =
+ writtenIdty &&
+ Underscore.where(pendings, { pubkey: writtenIdty.pub }).length === 0
+ ? [writtenIdty]
+ : [];
+ const found = pendings.concat(
+ nonPendings.map((i: any) => {
+ // Use the correct field
+ i.pubkey = i.pub;
+ return i;
+ })
+ );
+ return this.fillIdentitiesRevocation(found);
+ }
+
+ private async fillIdentitiesRevocation(
+ identities: DBIdentity[]
+ ): Promise<DBIdentity[]> {
return await Promise.all<DBIdentity>(
- found.map(async (f) => {
+ identities.map(async (f) => {
const ms = await this.mindexDAL.getReducedMSForImplicitRevocation(
f.pubkey
);
diff --git a/app/lib/dal/indexDAL/abstract/IIndexDAO.ts b/app/lib/dal/indexDAL/abstract/IIndexDAO.ts
index 1c1a08cd8052ec1a003e478b563ea2ef5562dc15..e6ec8965ae19f0848afb1af2ebbde887d27caec6 100644
--- a/app/lib/dal/indexDAL/abstract/IIndexDAO.ts
+++ b/app/lib/dal/indexDAL/abstract/IIndexDAO.ts
@@ -19,6 +19,8 @@ export interface IIndexDAO extends ReduceableDAO<IindexEntry> {
searchThoseMatching(search: string): Promise<OldIindexEntry[]>;
+ getOldFromPubkey(pub: string): Promise<OldIindexEntry | null>;
+
getFullFromUID(uid: string): Promise<FullIindexEntry>;
getFullFromPubkey(pub: string): Promise<FullIindexEntry>;
diff --git a/app/lib/dal/indexDAL/leveldb/LevelDBIindex.ts b/app/lib/dal/indexDAL/leveldb/LevelDBIindex.ts
index c53f3dfc48a11b38ca1e4d721a5d9ef17a59e0c8..fd5010024ec958c2e6768c2ac5de27427f3c9ba1 100644
--- a/app/lib/dal/indexDAL/leveldb/LevelDBIindex.ts
+++ b/app/lib/dal/indexDAL/leveldb/LevelDBIindex.ts
@@ -280,4 +280,12 @@ export class LevelDBIindex extends LevelDBTable<IindexEntry[]>
.filter((u) => u.pub)
.concat(pubIdentities.filter((p) => p.pub));
}
+
+ async getOldFromPubkey(pub: string): Promise<OldIindexEntry | null> {
+ const identities = await this.findByPub(pub);
+ if (!identities.length) {
+ return null;
+ }
+ return OldTransformers.toOldIindexEntry(reduce(identities));
+ }
}
diff --git a/app/lib/dal/indexDAL/sqlite/SqliteIIndex.ts b/app/lib/dal/indexDAL/sqlite/SqliteIIndex.ts
index fdbadbdaf23fdb168c1bfa76fee797d7e226e7b4..0ad31596c08242a2b4fafee86ef350d9f13c64bb 100644
--- a/app/lib/dal/indexDAL/sqlite/SqliteIIndex.ts
+++ b/app/lib/dal/indexDAL/sqlite/SqliteIIndex.ts
@@ -1,4 +1,4 @@
-import { FullIindexEntry, IindexEntry, Indexer } from "../../../indexer";
+import {FullIindexEntry, IindexEntry, Indexer, reduce} from "../../../indexer";
import { SQLiteDriver } from "../../drivers/SQLiteDriver";
import { MonitorExecutionTime } from "../../../debug/MonitorExecutionTime";
import { IIndexDAO } from "../abstract/IIndexDAO";
@@ -212,6 +212,18 @@ export class SqliteIIndex extends SqliteTable<IindexEntry>
return (await this.getFromUID(uid)) as FullIindexEntry;
}
+ @MonitorExecutionTime()
+ async getOldFromPubkey(pub: string): Promise<OldIindexEntry | null> {
+ const entries = await this.find(
+ "SELECT * FROM iindex WHERE pub = ? order by writtenOn ASC",
+ [pub]
+ );
+ if (!entries.length) {
+ return null;
+ }
+ return OldTransformers.toOldIindexEntry(reduce(entries));
+ }
+
@MonitorExecutionTime()
async getMembers(): Promise<{ pubkey: string; uid: string | null }[]> {
const members = await this.find(
diff --git a/app/lib/dal/sqliteDAL/IdentityDAL.ts b/app/lib/dal/sqliteDAL/IdentityDAL.ts
index 96d602a0af9da5b84031716ff0f3d18bcb54938b..851b27c0d7b0c7eb6dca672d88e6c8bb1d3e28df 100644
--- a/app/lib/dal/sqliteDAL/IdentityDAL.ts
+++ b/app/lib/dal/sqliteDAL/IdentityDAL.ts
@@ -328,6 +328,10 @@ export class IdentityDAL extends AbstractSQLite<DBIdentity> {
});
}
+ findByPub(pub: string) {
+ return this.sqlFind({ pubkey: pub });
+ }
+
async trimExpiredIdentities(medianTime: number) {
await this.exec(
"DELETE FROM " +
diff --git a/app/modules/bma/lib/controllers/wot.ts b/app/modules/bma/lib/controllers/wot.ts
index 61e869b06e7ae01296a122ab523f990b6cc943dc..73422c518b6fe41820b115de7237280ecae6a613 100644
--- a/app/modules/bma/lib/controllers/wot.ts
+++ b/app/modules/bma/lib/controllers/wot.ts
@@ -132,9 +132,16 @@ export class WOTBinding extends AbstractController {
async certifiersOf(req: any): Promise<HttpCertifications> {
const search = await ParametersService.getSearchP(req);
- const idty = (await this.server.dal.getWrittenIdtyByPubkeyOrUIdForHashingAndIsMember(
- search
- )) as FullIindexEntry;
+ let idty: FullIindexEntry;
+ if (ParametersService.getIsPubkey(req)) {
+ idty = (await this.server.dal.getWrittenIdtyByPubkeyForHashingAndIsMember(
+ search
+ )) as FullIindexEntry;
+ } else {
+ idty = (await this.server.dal.getWrittenIdtyByPubkeyOrUIdForHashingAndIsMember(
+ search
+ )) as FullIindexEntry;
+ }
const certs = await this.server.dal.certsToTarget(
idty.pub,
IdentityDTO.getTargetHash(idty)
@@ -180,7 +187,15 @@ export class WOTBinding extends AbstractController {
async requirements(req: any): Promise<HttpRequirements> {
const search = await ParametersService.getSearchP(req);
- const identities: any = await this.IdentityService.searchIdentities(search);
+ let identities: any = [];
+ if (ParametersService.getIsPubkey(req)) {
+ if (!BMAConstants.PUBLIC_KEY.test(search)) {
+ throw BMAConstants.ERRORS.NO_IDTY_MATCHING_PUB_OR_UID;
+ }
+ identities = await this.IdentityService.searchIdentitiesByPubkey(search);
+ } else {
+ identities = await this.IdentityService.searchIdentities(search);
+ }
const all: HttpIdentityRequirement[] = await this.BlockchainService.requirementsOfIdentities(
identities
);
@@ -229,9 +244,16 @@ export class WOTBinding extends AbstractController {
async certifiedBy(req: any): Promise<HttpCertifications> {
const search = await ParametersService.getSearchP(req);
- const idty = (await this.server.dal.getWrittenIdtyByPubkeyOrUIdForHashingAndIsMember(
- search
- )) as FullIindexEntry;
+ let idty: FullIindexEntry;
+ if (ParametersService.getIsPubkey(req)) {
+ idty = (await this.server.dal.getWrittenIdtyByPubkeyForHashingAndIsMember(
+ search
+ )) as FullIindexEntry;
+ } else {
+ idty = (await this.server.dal.getWrittenIdtyByPubkeyOrUIdForHashingAndIsMember(
+ search
+ )) as FullIindexEntry;
+ }
const certs = await this.server.dal.certsFrom(idty.pub);
const theCerts: HttpCertification[] = [];
for (const cert of certs) {
diff --git a/app/modules/bma/lib/parameters.ts b/app/modules/bma/lib/parameters.ts
index 49a437f26c53ad1e00efcd9146f2bdcea021c730..c5463ecd963be1655785292a448d83d6f42179d0 100644
--- a/app/modules/bma/lib/parameters.ts
+++ b/app/modules/bma/lib/parameters.ts
@@ -96,6 +96,16 @@ export class ParametersService {
callback(null, matches[0]);
};
+ static getIsPubkey(req: any): boolean {
+ const value = req.query.pubkey;
+ return (
+ value !== null &&
+ value !== undefined &&
+ value !== "false" &&
+ value !== false
+ );
+ }
+
static getPubkeyP(req: any) {
return Q.nbind(ParametersService.getPubkey, this)(req);
}
diff --git a/app/service/IdentityService.ts b/app/service/IdentityService.ts
index 676b8602a57b183a8582444c9be37e77ca39cd12..f3173f885c8f1adc9595879298f1798ef10d52f7 100644
--- a/app/service/IdentityService.ts
+++ b/app/service/IdentityService.ts
@@ -54,6 +54,10 @@ export class IdentityService extends FIFOService {
return this.dal.searchJustIdentities(search);
}
+ searchIdentitiesByPubkey(pubkey: string) {
+ return this.dal.searchJustIdentitiesByPubkey(pubkey);
+ }
+
async findMember(search: string) {
let idty = null;
if (search.match(constants.PUBLIC_KEY)) {
diff --git a/test/dal/sources-dal.ts b/test/dal/sources-dal.ts
index 7faac7713596cdc8dad080389a69716049598b96..ed4d9ab836ecd8cafe6ef62b85ac0f86ca3e575c 100644
--- a/test/dal/sources-dal.ts
+++ b/test/dal/sources-dal.ts
@@ -18,30 +18,70 @@ const should = require('should');
let dal:FileDAL
-describe("Source DAL", function(){
+describe("Source DAL", function() {
+ const pubkeyA = 'BYfWYFrsyjpvpFysgu19rGK3VHBkz4MqmQbNyEuVU64g';
+ const pubkeyB = 'DSz4rgncXCytsUMW2JU2yhLquZECD2XpEkpP9gG5HyAx';
before(async () => {
dal = new FileDAL(await Directory.getHomeParams(true, 'db0'), async (name: string) => Directory.getHomeDB(true, name), async (name: string) => Directory.getHomeLevelDB(true, name))
await dal.init({} as any)
})
- it('should be able to feed the sindex with unordered rows', async () => {
+ it('should be able to fill the sindex with unordered rows', async () => {
await dal.sindexDAL.insertBatch([
- { op: 'UPDATE', tx: null, identifier: 'SOURCE_1', pos: 4, written_on: '139-H', writtenOn: 139, written_time: 4500, consumed: true, conditions: 'SIG(ABC)' },
- { op: 'CREATE', tx: null, identifier: 'SOURCE_1', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: 'SIG(ABC)' },
- { op: 'CREATE', tx: null, identifier: 'SOURCE_2', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: 'SIG(ABC)' },
- { op: 'CREATE', tx: null, identifier: 'SOURCE_3', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: 'SIG(DEF)' }
+ { op: 'UPDATE', tx: null, identifier: 'SOURCE_1', pos: 4, written_on: '139-H', writtenOn: 139, written_time: 4500, consumed: true, conditions: `SIG(${pubkeyA})` },
+ { op: 'CREATE', tx: null, identifier: 'SOURCE_1', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: `SIG(${pubkeyA})` },
+ { op: 'CREATE', tx: null, identifier: 'SOURCE_2', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: `SIG(${pubkeyA})` },
+ { op: 'CREATE', tx: null, identifier: 'SOURCE_3', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: `SIG(${pubkeyB})` }
] as any);
(await dal.sindexDAL.findByIdentifier('SOURCE_1')).should.have.length(2);
(await dal.sindexDAL.findByPos(4)).should.have.length(4);
// Source availability
- const sourcesOfDEF = await dal.sindexDAL.getAvailableForPubkey('DEF');
- sourcesOfDEF.should.have.length(1);
- const sourcesOfABC = await dal.sindexDAL.getAvailableForPubkey('ABC');
- sourcesOfABC.should.have.length(1);
+ const sourcesOfA = await dal.sindexDAL.getAvailableForPubkey(pubkeyA);
+ sourcesOfA.should.have.length(1);
+ const sourcesOfB = await dal.sindexDAL.getAvailableForPubkey(pubkeyB);
+ sourcesOfB.should.have.length(1);
const source1 = await dal.sindexDAL.getTxSource('SOURCE_1', 4) as any
source1.should.have.property('consumed').equal(true);
const source2 = await dal.sindexDAL.getTxSource('SOURCE_2', 4) as any
source2.should.have.property('consumed').equal(false);
+
+ // Check sources not available after block deletion
+ await dal.sindexDAL.removeBlock('126-H');
+ (await dal.sindexDAL.findByIdentifier('SOURCE_1')).should.have.length(1);
+ should(await dal.sindexDAL.getTxSource('SOURCE_2', 4) as any).be.null();
+ should(await dal.sindexDAL.getTxSource('SOURCE_3', 4) as any).be.null();
+ (await dal.sindexDAL.findByPos(4)).should.have.length(1);
+ await dal.sindexDAL.removeBlock('139-H');
+ (await dal.sindexDAL.findByIdentifier('SOURCE_1')).should.have.length(0);
+ (await dal.sindexDAL.findByPos(4)).should.have.length(0);
+ (await dal.sindexDAL.getAvailableForPubkey(pubkeyA)).should.have.length(0);
+ (await dal.sindexDAL.getAvailableForPubkey(pubkeyB)).should.have.length(0);
+ should(await dal.sindexDAL.getTxSource('SOURCE_1', 4) as any).be.null();
+ should(await dal.sindexDAL.getTxSource('SOURCE_2', 4) as any).be.null();
+ should(await dal.sindexDAL.getTxSource('SOURCE_3', 4) as any).be.null();
+ })
+
+ it('should be able to read sindex by pubkey', async () => {
+ // Test insertion, using complex condition
+ await dal.sindexDAL.insertBatch([
+ { op: 'CREATE', tx: null, identifier: 'SOURCE_4', pos: 4, written_on: '139-H', writtenOn: 139, written_time: 2000, consumed: false, conditions: `SIG(${pubkeyA})` },
+ { op: 'CREATE', tx: null, identifier: 'SOURCE_5', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: `(SIG(${pubkeyA}) && SIG(${pubkeyB}))` },
+ { op: 'CREATE', tx: null, identifier: 'SOURCE_6', pos: 4, written_on: '126-H', writtenOn: 126, written_time: 2000, consumed: false, conditions: `(XHX(3EB4702F2AC2FD3FA4FDC46A4FC05AE8CDEE1A85F2AC2FD3FA4FDC46A4FC01CA) || SIG(${pubkeyB}))` }
+ ] as any);
+
+ // Check sources availability by pubkey
+ let sourcesOfA = await dal.sindexDAL.getAvailableForPubkey(pubkeyA);
+ sourcesOfA.should.have.length(2);
+ let sourcesOfB = await dal.sindexDAL.getAvailableForPubkey(pubkeyB);
+ sourcesOfB.should.have.length(2);
+
+ // Check sources not available after block deletion
+ await dal.sindexDAL.removeBlock('126-H');
+ await dal.sindexDAL.removeBlock('139-H');
+ sourcesOfA = await dal.sindexDAL.getAvailableForPubkey(pubkeyA);
+ sourcesOfA.should.have.length(0);
+ sourcesOfB = await dal.sindexDAL.getAvailableForPubkey(pubkeyB);
+ sourcesOfB.should.have.length(0);
})
})
diff --git a/test/integration/identity/identity-test.ts b/test/integration/identity/identity-test.ts
index 6966e9971ebf9b7d850756824698fa2cf949ca04..2a60a7ffb6f58ba0fcf6c4a4eef072101ec022a7 100644
--- a/test/integration/identity/identity-test.ts
+++ b/test/integration/identity/identity-test.ts
@@ -192,6 +192,13 @@ describe("Identities collision", function() {
});
});
+ it('should have certifiers-of/:pubkey of cat giving results', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/certifiers-of/HgTTJLAQ5sqfknMq7yLPZbehtuLSsKj9CxWN7k8QvYJd?pubkey', { json: true }), function(res:HttpCertifications) {
+ res.should.have.property('pubkey').equal('HgTTJLAQ5sqfknMq7yLPZbehtuLSsKj9CxWN7k8QvYJd');
+ res.should.have.property('uid').equal('cat');
+ });
+ });
+
it('should have certifiers-of/tic giving results', function() {
return expectAnswer(rp('http://127.0.0.1:7799/wot/certifiers-of/tic', { json: true }), function(res:HttpCertifications) {
res.should.have.property('pubkey').equal('DNann1Lh55eZMEDXeYt59bzHbA3NJR46DeQYCS2qQdLV');
@@ -213,6 +220,13 @@ describe("Identities collision", function() {
});
});
+ it('should have certifiers-of/:pubkey of tic giving results', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/certifiers-of/DNann1Lh55eZMEDXeYt59bzHbA3NJR46DeQYCS2qQdLV?pubkey', { json: true }), function(res:HttpCertifications) {
+ res.should.have.property('pubkey').equal('DNann1Lh55eZMEDXeYt59bzHbA3NJR46DeQYCS2qQdLV');
+ res.should.have.property('uid').equal('tic');
+ });
+ });
+
it('should have certifiers-of/toc giving results', function() {
return expectAnswer(rp('http://127.0.0.1:7799/wot/certifiers-of/toc', { json: true }), function(res:HttpCertifications) {
res.should.have.property('pubkey').equal('DKpQPUL4ckzXYdnDRvCRKAm1gNvSdmAXnTrJZ7LvM5Qo');
@@ -234,6 +248,13 @@ describe("Identities collision", function() {
});
});
+ it('should have certifiers-of/:pubkey of toc giving results', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/certifiers-of/DKpQPUL4ckzXYdnDRvCRKAm1gNvSdmAXnTrJZ7LvM5Qo?pubkey', { json: true }), function(res:HttpCertifications) {
+ res.should.have.property('pubkey').equal('DKpQPUL4ckzXYdnDRvCRKAm1gNvSdmAXnTrJZ7LvM5Qo');
+ res.should.have.property('uid').equal('toc');
+ });
+ });
+
it('requirements of cat', function() {
return expectAnswer(rp('http://127.0.0.1:7799/wot/requirements/cat', { json: true }), function(res:HttpRequirements) {
res.should.have.property('identities').be.an.Array;
@@ -270,6 +291,46 @@ describe("Identities collision", function() {
});
});
+ it('requirements by pubkey of cat', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/requirements/HgTTJLAQ5sqfknMq7yLPZbehtuLSsKj9CxWN7k8QvYJd?pubkey', { json: true }), function(res:HttpRequirements) {
+ res.should.have.property('identities').be.an.Array;
+ res.should.have.property('identities').have.length(1);
+ res.identities[0].should.have.property('pubkey').equal('HgTTJLAQ5sqfknMq7yLPZbehtuLSsKj9CxWN7k8QvYJd');
+ res.identities[0].should.have.property('uid').equal('cat');
+ res.identities[0].should.have.property('meta').property('timestamp');
+ res.identities[0].should.have.property('wasMember').equal(true);
+ res.identities[0].should.have.property('expired').equal(false); // Because it has been a member once! So its identity will exist forever.
+ res.identities[0].should.have.property('outdistanced').equal(false);
+ res.identities[0].should.have.property('isSentry').equal(true); // dSen = 2, cat has issued and received 2 certs with tic and toc
+ res.identities[0].should.have.property('certifications').have.length(2);
+ res.identities[0].should.have.property('membershipPendingExpiresIn').equal(0);
+ res.identities[0].should.have.property('membershipExpiresIn').greaterThan(9000);
+ });
+ });
+
+ it('requirements by pubkey of man1', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/requirements/12AbjvYY5hxV4v2KrN9pnGzgFxogwrzgYyncYHHsyFDK?pubkey', { json: true }), function(res:HttpRequirements) {
+ res.should.have.property('identities').be.an.Array;
+ res.should.have.property('identities').have.length(1);
+ res.identities[0].should.have.property('pubkey').equal('12AbjvYY5hxV4v2KrN9pnGzgFxogwrzgYyncYHHsyFDK');
+ res.identities[0].should.have.property('uid').equal('man1');
+ res.identities[0].should.have.property('meta').property('timestamp');
+ res.identities[0].should.have.property('expired').equal(false);
+ res.identities[0].should.have.property('outdistanced').equal(false);
+ res.identities[0].should.have.property('isSentry').equal(false); // Not a member, also dSen = 2, but man1 has only 1 certification
+ res.identities[0].should.have.property('certifications').length(1);
+ res.identities[0].certifications[0].should.have.property('from').equal('2LvDg21dVXvetTD9GdkPLURavLYEqP3whauvPWX4c2qc');
+ res.identities[0].certifications[0].should.have.property('to').equal('12AbjvYY5hxV4v2KrN9pnGzgFxogwrzgYyncYHHsyFDK');
+ res.identities[0].certifications[0].should.have.property('expiresIn').greaterThan(0);
+ res.identities[0].should.have.property('membershipPendingExpiresIn').greaterThan(9000);
+ res.identities[0].should.have.property('membershipExpiresIn').equal(0);
+ });
+ });
+
+ it('requirements by invalid pubkey', function() {
+ return expectError(404, "No identity matching this pubkey or uid", rp('http://127.0.0.1:7799/wot/requirements/cat?pubkey', { json: true }));
+ });
+
it('should have certified-by/tic giving results', function() {
return expectAnswer(rp('http://127.0.0.1:7799/wot/certified-by/tic', { json: true }), function(res:HttpCertifications) {
res.should.have.property('pubkey').equal('DNann1Lh55eZMEDXeYt59bzHbA3NJR46DeQYCS2qQdLV');
@@ -298,6 +359,13 @@ describe("Identities collision", function() {
});
});
+ it('should have certified-by/:pubkey of tic giving results', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/certified-by/DNann1Lh55eZMEDXeYt59bzHbA3NJR46DeQYCS2qQdLV?pubkey', { json: true }), function(res:HttpCertifications) {
+ res.should.have.property('pubkey').equal('DNann1Lh55eZMEDXeYt59bzHbA3NJR46DeQYCS2qQdLV');
+ res.should.have.property('uid').equal('tic');
+ });
+ });
+
it('should have certified-by/tac giving results', function() {
return expectAnswer(rp('http://127.0.0.1:7799/wot/certified-by/tac', { json: true }), function(res:HttpCertifications) {
res.should.have.property('pubkey').equal('2LvDg21dVXvetTD9GdkPLURavLYEqP3whauvPWX4c2qc');
@@ -308,6 +376,13 @@ describe("Identities collision", function() {
});
});
+ it('should have certified-by/:pubkey of tac giving results', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/certified-by/2LvDg21dVXvetTD9GdkPLURavLYEqP3whauvPWX4c2qc?pubkey', { json: true }), function(res:HttpCertifications) {
+ res.should.have.property('pubkey').equal('2LvDg21dVXvetTD9GdkPLURavLYEqP3whauvPWX4c2qc');
+ res.should.have.property('uid').equal('tac');
+ });
+ });
+
it('should have certified-by/cat giving results', function() {
return expectAnswer(rp('http://127.0.0.1:7799/wot/certified-by/cat', { json: true }), function(res:HttpCertifications) {
res.should.have.property('pubkey').equal('HgTTJLAQ5sqfknMq7yLPZbehtuLSsKj9CxWN7k8QvYJd');
@@ -343,6 +418,13 @@ describe("Identities collision", function() {
});
});
+ it('should have certified-by/:pubkey of cat giving results', function() {
+ return expectAnswer(rp('http://127.0.0.1:7799/wot/certified-by/HgTTJLAQ5sqfknMq7yLPZbehtuLSsKj9CxWN7k8QvYJd?pubkey', { json: true }), function(res:HttpCertifications) {
+ res.should.have.property('pubkey').equal('HgTTJLAQ5sqfknMq7yLPZbehtuLSsKj9CxWN7k8QvYJd');
+ res.should.have.property('uid').equal('cat');
+ });
+ });
+
it('requirements of man2', function() {
return expectAnswer(rp('http://127.0.0.1:7799/wot/requirements/man2', { json: true }), function(res:HttpRequirements) {
res.should.have.property('identities').be.an.Array;