9416468997

Committed 07 Jun 2024 11:46AM UTC coverage: 69.3% (+1.2%) from 68.144%

Build # 9416468997

Build Type

Pull #215

github

Committed by

web-flow

Commit Message

Merge ff72c3dfc into 78838eaef

Pull Request Pull Request #215: feat: Backup and Restore

Run Details

1087 of 1756 branches covered (61.9%)

Branch coverage included in aggregate %.

218 of 264 new or added lines in 29 files covered. (82.58%)

3 existing lines in 2 files now uncovered.

2290 of 3117 relevant lines covered (73.47%)

19.41 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

93.75

/src/pluto/backup/BackupManager.ts

import * as Domain from "../../domain";
import * as Versions from "./versions";
import { Pluto } from "../Pluto";
import { PlutoRepositories } from "../repositories";
import { isEmpty } from "../../utils";
import { IBackupTask, IRestoreTask } from "./versions/interfaces";

/**
 * BackupManager
 * handle the different versions of backup and restore
 */
export class BackupManager {
  constructor(
    private readonly Pluto: Pluto,
    private readonly Repositories: PlutoRepositories
  ) {}

  /**
   * convert stored data to JSON
   * 
   * @param version - backup schema version
   * @returns {Promise<Domain.Backup.Schema>}
   */
  backup(version?: string) {
    const task = this.getBackupTask(version);
    return task.run();
  }

  /**
   * convert JSON to stored data
   * 
   * @param backup 
   */
  async restore(backup: Domain.Backup.Schema) {
    await this.assertStoreIsEmpty();
    const task = this.getRestoreTask(backup);
    await task.run();
  }

  private getBackupTask(version: string = Domain.Backup.defaultVersion): IBackupTask {
    switch (version) {
      case "0.0.1":
        return new Versions.v0_0_1.BackupTask(this.Pluto, this.Repositories);
    }

    throw new Domain.PlutoError.BackupNotFoundError();
  }

  private getRestoreTask(backup: Domain.Backup.Schema): IRestoreTask {
    const version = backup.version ?? Domain.Backup.defaultVersion;

    switch (version) {
      case "0.0.1":
        return new Versions.v0_0_1.RestoreTask(this.Pluto, backup);
    }

    throw new Domain.PlutoError.RestoreNotFoundError();
  }

  private async assertStoreIsEmpty() {
    const credentials = await this.Repositories.Credentials.getModels();
    const dids = await this.Repositories.DIDs.getModels();
    const keys = await this.Repositories.Keys.getModels();
    const link_secret = await this.Repositories.LinkSecrets.getModels();
    const messages = await this.Repositories.Messages.getModels();

    if (
      isEmpty(credentials) &&
      isEmpty(dids) &&
      isEmpty(keys) &&
      isEmpty(link_secret) &&
      isEmpty(messages)
    ) {
      return true;
    }

    throw new Domain.PlutoError.StoreNotEmptyError();
  }
}

1	import * as Domain from "../../domain";
2	import * as Versions from "./versions";
3	import { Pluto } from "../Pluto";
4	import { PlutoRepositories } from "../repositories";
5	import { isEmpty } from "../../utils";
6	import { IBackupTask, IRestoreTask } from "./versions/interfaces";
7
8	/**
9	* BackupManager
10	* handle the different versions of backup and restore
11	*/
12	export class BackupManager {
13	constructor(
14	private readonly Pluto: Pluto,
15	private readonly Repositories: PlutoRepositories
16	) {}
17
18	/**
19	* convert stored data to JSON
20	*
21	* @param version - backup schema version
22	* @returns {Promise<Domain.Backup.Schema>}
23	*/
24	backup(version?: string) {
25	const task = this.getBackupTask(version);	9✔
26	return task.run();	9✔
27	}
28
29	/**
30	* convert JSON to stored data
31	*
32	* @param backup
33	*/
34	async restore(backup: Domain.Backup.Schema) {
35	await this.assertStoreIsEmpty();	15✔
36	const task = this.getRestoreTask(backup);	10✔
37	await task.run();	10✔
38	}
39
40	private getBackupTask(version: string = Domain.Backup.defaultVersion): IBackupTask {	9✔
41	switch (version) {	9✔
42	case "0.0.1":
43	return new Versions.v0_0_1.BackupTask(this.Pluto, this.Repositories);	9✔
44	}
45
NEW 46	throw new Domain.PlutoError.BackupNotFoundError();	×
47	}
48
49	private getRestoreTask(backup: Domain.Backup.Schema): IRestoreTask {
50	const version = backup.version ?? Domain.Backup.defaultVersion;	10✔
51
52	switch (version) {	10✔
53	case "0.0.1":
54	return new Versions.v0_0_1.RestoreTask(this.Pluto, backup);	10✔
55	}
56
NEW 57	throw new Domain.PlutoError.RestoreNotFoundError();	×
58	}
59
60	private async assertStoreIsEmpty() {
61	const credentials = await this.Repositories.Credentials.getModels();	15✔
62	const dids = await this.Repositories.DIDs.getModels();	15✔
63	const keys = await this.Repositories.Keys.getModels();	15✔
64	const link_secret = await this.Repositories.LinkSecrets.getModels();	15✔
65	const messages = await this.Repositories.Messages.getModels();	15✔
66
67	if (	15✔
68	isEmpty(credentials) &&	64✔
69	isEmpty(dids) &&
70	isEmpty(keys) &&
71	isEmpty(link_secret) &&
72	isEmpty(messages)
73	) {
74	return true;	10✔
75	}
76
77	throw new Domain.PlutoError.StoreNotEmptyError();	5✔
78	}
79	}

input-output-hk / atala-prism-wallet-sdk-ts / 9416468997

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous