-
Notifications
You must be signed in to change notification settings - Fork 19
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Co-authored-by: filipgolem <[email protected]>
- Loading branch information
1 parent
f91fa33
commit 1e02cb1
Showing
13 changed files
with
692 additions
and
150 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,123 @@ | ||
| import * as crypto from "crypto"; | ||
| import * as eccrypto from "eccrypto"; | ||
| import * as secp256k1 from "secp256k1"; | ||
|
|
||
| export function rand_hex(length: number): string { | ||
| let byte_sz = Math.floor(length / 2); | ||
| return crypto.randomBytes(byte_sz).toString("hex"); | ||
| } | ||
|
|
||
| export class PrivateKey { | ||
| inner!: Buffer; | ||
|
|
||
| constructor() { | ||
| this.inner = eccrypto.generatePrivate(); | ||
| } | ||
|
|
||
| static from(buffer: Buffer): PrivateKey { | ||
| let key = Object.create(this.prototype); | ||
| key.inner = buffer; | ||
| return key; | ||
| } | ||
|
|
||
| static fromHex(hex: string): PublicKey { | ||
| let inner = Buffer.from(hex, "hex"); | ||
| return PublicKey.from(inner); | ||
| } | ||
|
|
||
| publicKey(compressed: boolean = true): PublicKey { | ||
| let buffer = compressed | ||
| ? eccrypto.getPublicCompressed(this.inner) | ||
| : eccrypto.getPublic(this.inner); | ||
| return PublicKey.from(buffer); | ||
| } | ||
|
|
||
| async derive(publicKey: PublicKey): Promise<Buffer> { | ||
| return await eccrypto.derive(this.inner, publicKey.inner); | ||
| } | ||
|
|
||
| async sign(msg: Buffer) { | ||
| return await eccrypto.sign(this.inner, msg); | ||
| } | ||
|
|
||
| toString(): string { | ||
| return this.inner.toString("hex"); | ||
| } | ||
| } | ||
|
|
||
| export class PublicKey { | ||
| inner!: Buffer; | ||
|
|
||
| private constructor() {} | ||
|
|
||
| static from(buffer: Buffer): PublicKey { | ||
| let key = Object.create(this.prototype); | ||
| key.inner = buffer; | ||
| return key; | ||
| } | ||
|
|
||
| static fromHex(hex: string): PublicKey { | ||
| let inner = Buffer.from(hex, "hex"); | ||
| return PublicKey.from(inner); | ||
| } | ||
|
|
||
| toString(): string { | ||
| return this.inner.toString("hex"); | ||
| } | ||
| } | ||
|
|
||
| export class CryptoCtx { | ||
| priv_key!: PrivateKey; | ||
| ephem_key!: Buffer; | ||
|
|
||
| static async from(pub_key: PublicKey, priv_key?: PrivateKey): Promise<CryptoCtx> { | ||
| priv_key = priv_key ? priv_key : new PrivateKey(); | ||
| let ephem_key = Buffer.from(secp256k1.ecdh(pub_key.inner, priv_key.inner)); | ||
| return new CryptoCtx(priv_key, ephem_key); | ||
| } | ||
|
|
||
| private constructor(priv_key: PrivateKey, ephem_key: Buffer) { | ||
| this.priv_key = priv_key; | ||
| this.ephem_key = ephem_key; | ||
| } | ||
|
|
||
| encrypt(data: Buffer): Buffer { | ||
| let iv = crypto.randomBytes(12); | ||
| let cipher = crypto.createCipheriv("aes-256-gcm", this.ephem_key, iv); | ||
|
|
||
| let chunk_1 = cipher.update(data); | ||
| let chunk_2 = cipher.final(); | ||
| let tag = cipher.getAuthTag(); | ||
|
|
||
| let buffer = Buffer.alloc(1 + iv.length + 1 + tag.length, 0, 'binary'); | ||
| let off = 0; | ||
|
|
||
| buffer.writeUInt8(iv.length, off); | ||
| off += 1; | ||
| iv.copy(buffer, off); | ||
| off += iv.length; | ||
| buffer.writeUInt8(tag.length, off); | ||
| off += 1; | ||
| tag.copy(buffer, off); | ||
|
|
||
| return Buffer.concat([buffer, chunk_1, chunk_2]); | ||
| } | ||
|
|
||
| decrypt(data: Buffer): Buffer { | ||
| let off = 0; | ||
| let iv_length = data.readUInt8(off); | ||
| off += 1; | ||
| let iv = data.slice(off, off + iv_length); | ||
| off += iv_length; | ||
| let tag_length = data.readUInt8(off); | ||
| off += 1; | ||
| let tag = data.slice(off, off + tag_length); | ||
| off += tag_length; | ||
| let enc = data.slice(off); | ||
|
|
||
| var cipher = crypto.createDecipheriv("aes-256-gcm", this.ephem_key, iv); | ||
| cipher.setAuthTag(tag); | ||
|
|
||
| return Buffer.concat([cipher.update(enc), cipher.final()]); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,9 +1,9 @@ | ||
| import events from "events"; | ||
| import { Engine, Task, vm } from "./runner"; | ||
| import { Engine, Task, sgx, vm } from "./runner"; | ||
| import { WorkContext } from "./runner/ctx"; | ||
| import * as props from "./props"; | ||
| import * as rest from "./rest"; | ||
| import * as storage from "./storage"; | ||
| import * as utils from "./utils"; | ||
|
|
||
| export { Engine, Task, vm, WorkContext, props, rest, storage, utils }; | ||
| export { Engine, Task, sgx, vm, WorkContext, props, rest, storage, utils }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.