Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

services: Ingest tss transactions #46

Merged
merged 129 commits into from
Oct 23, 2024
Merged

services: Ingest tss transactions #46

merged 129 commits into from
Oct 23, 2024

Conversation

gouthamp-stellar
Copy link
Contributor

@gouthamp-stellar gouthamp-stellar commented Sep 30, 2024

What

The ingestion part of TSS as described in:
https://docs.google.com/document/d/1a5Rv4GL2E_rjPdBsSOxOBAcpDfSw5iSyApQE_KngpRU/edit?pli=1#heading=h.jkatqoun9sqv

This also replaces the payment history with rpc, removing all dependency on core

Why

We need to update the status of transactions that were successfully submitted to core via RPC

Known limitations

N/A

Issue that this PR addresses

https://app.asana.com/0/1207947010297920/1208138733594331

Checklist

PR Structure

  • It is not possible to break this PR down into smaller PRs.
  • This PR does not mix refactoring changes with feature changes.
  • This PR's title starts with name of package that is most changed in the PR, or all if the changes are broad or impact many packages.

Thoroughness

  • This PR adds tests for the new functionality or fixes.
  • All updated queries have been tested (refer to this check if the data set returned by the updated query is expected to be same as the original one).

Release

  • This is not a breaking change.
  • This is ready to be tested in development.
  • The new functionality is gated with a feature flag if this is not ready for production.

adding semicolons
…ransaction_hash

...also remove outgoing/incoming_status and have one status column
commit fb807aa
Author: gouthamp-stellar <[email protected]>
Date:   Tue Sep 3 10:28:49 2024 -0700

    remove the index on try_transaction_xdr and add column/index on try_transaction_hash

    ...also remove outgoing/incoming_status and have one status column

commit 6fc0dc2
Author: gouthamp-stellar <[email protected]>
Date:   Tue Sep 3 08:58:46 2024 -0700

    missing ,

commit a9cf4e3
Author: gouthamp-stellar <[email protected]>
Date:   Tue Sep 3 01:55:23 2024 -0700

    make hash primary key instead of xdr

commit c0f9d32
Author: gouthamp-stellar <[email protected]>
Date:   Fri Aug 30 15:18:27 2024 -0700

    moving all migrations to one file

commit 2de9898
Author: gouthamp-stellar <[email protected]>
Date:   Fri Aug 30 15:16:53 2024 -0700

    adding semicolons

    adding semicolons

commit 373c71a
Author: gouthamp-stellar <[email protected]>
Date:   Fri Aug 30 15:12:24 2024 -0700

    update

commit 3f9f9f0
Author: gouthamp-stellar <[email protected]>
Date:   Fri Aug 30 15:12:00 2024 -0700

    remove empty lines

commit 9920f48
Author: gouthamp-stellar <[email protected]>
Date:   Fri Aug 30 15:06:40 2024 -0700

    TSS tables and the channel interface

commit a58d519
Author: gouthamp-stellar <[email protected]>
Date:   Fri Aug 30 10:55:22 2024 -0700

    tables and interfaces for TSS
Copy link
Contributor

@CaioTeixeira95 CaioTeixeira95 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM. I only left some minor changes suggestions.

@@ -67,3 +91,43 @@ func (s *store) UpsertTry(ctx context.Context, txHash string, feeBumpTxHash stri
}
return nil
}

func (s *store) GetTransaction(ctx context.Context, hash string) (Transaction, error) {
q := `SELECT * from tss_transactions where transaction_hash = $1`
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Can we be consistent with the keyword letter's case in these queries?

err := s.DB.GetContext(ctx, &transaction, q, hash)
if err != nil {
if errors.Is(err, sql.ErrNoRows) {
fmt.Println("empty")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
fmt.Println("empty")

if errors.Is(err, sql.ErrNoRows) {
return Try{}, nil
}
return Try{}, fmt.Errorf("getting try: %w", err)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
return Try{}, fmt.Errorf("getting try: %w", err)
return Try{}, fmt.Errorf("getting try by xdr: %w", err)

Base automatically changed from webhook_handler_service to main October 22, 2024 23:54
@gouthamp-stellar gouthamp-stellar merged commit 3123476 into main Oct 23, 2024
5 checks passed
@gouthamp-stellar gouthamp-stellar deleted the rpc_ingestor branch October 23, 2024 20:05
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants