Transactions WIP

nodemon.json

@@ -6,4 +6,4 @@
   "events": {
     "start": "tslint -c ./tslint.json -t stylish 'src/**/*.ts'"
   }
-}
+}

src/transaction/index.ts

@@ -0,0 +1,2 @@
+export { txSchema } from "./tx.schema";
+export { txResolver } from "./tx.resolver";

src/transaction/schema/index.ts

@@ -0,0 +1,3 @@
+export { transactionType } from "./transaction.type";
+export { transactionQuery } from "./transaction.query";
+export { transactionSubscription } from "./transaction.subscription";

src/transaction/transaction.model.ts

@@ -0,0 +1,19 @@
+import stellar from "stellar-base";
+
+export default class Transaction {
+  public ID: string;
+  public ledgerSeq: number;
+  public index: number;
+  public body: string;
+  public result: string;
+  public meta: string;
+
+  constructor(data: { data: string }) {
+    this.ID = data.txid;
+    this.ledgerSeq = data.ledgerseq;
+    this.index = data.txIndex;
+    this.body = data.txBody;
+    this.result = data.txResult;
+    this.meta = data.txMeta;
+  }
+}

src/transaction/transaction.repo.ts

@@ -0,0 +1,21 @@
+import { IDatabase } from "pg-promise";
+import Transaction from "./transaction.model";
+
+export default class LedgersRepository {
+  private db: IDatabase<any>;
+
+  constructor(db: any) {
+    this.db = db;
+  }
+
+  // Tries to find a transaction by id;
+  public findByID(id: string): Promise<Transaction> {
+    return this.db.oneOrNone("SELECT * FROM txhistory WHERE txid = $1", id, res => new Transaction(res));
+  }
+
+  public findByLedgerSeq(ledgerSeq: number): Promise<Transaction[]> {
+    return this.db.any("SELECT * FROM txhistory WHERE ledgerseq = $1 ORDER BY txindex", ledgerSeq, res =>
+      res.map(t => new Transaction(t))
+    );
+  }
+}