go-steem · asuleymanov · May 24, 2017 · May 24, 2017 · May 24, 2017 · May 24, 2017
diff --git a/.gitignore b/.gitignore
diff --git a/LICENSE b/LICENSE
@@ -1,6 +1,6 @@
 The MIT License (MIT)
 
-Copyright (c) 2016 go-steem
+Copyright (c) 2016 steem-go
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

diff --git a/README.md b/README.md
@@ -1,93 +1,82 @@
-# go-steem/rpc
+# asuleymanov/steem-go
 
-[![GoDoc](https://godoc.org/github.com/go-steem/rpc?status.svg)](https://godoc.org/github.com/go-steem/rpc)
+[![GoDoc](https://godoc.org/github.com/asuleymanov/steem-go?status.svg)](https://godoc.org/github.com/asuleymanov/steem-go)
+[![Go Report Card](https://goreportcard.com/badge/github.com/asuleymanov/steem-go)](https://goreportcard.com/report/github.com/asuleymanov/steem-go)
 
-Golang RPC client library for [Steem](https://steem.io).
-
-## Compatibility
-
-`steemd 0.13.0`
+Golang RPC client library for [Steem](https://steemit.com).
 
 ## Usage
 
 ```go
-import "github.com/go-steem/rpc"
+import "github.com/asuleymanov/steem-go"
 ```
 
-This package is still very much in development, so `gopkg.in` is not yet available.
-
-## Installation
-
-This package calls [bitcoin-core/secp256k1](https://github.com/bitcoin-core/secp256k1)
-using CGO to implement signed transactions, so you need to install `secp256k1` first.
-Then it will be possible to build `go-steem/rpc`.
-
-In case you don't need signed transactions, i.e. you don't need to use
-`network_broadcast_api`, it is possible to build the package with `nosigning`
-tag to exclude the functionality:
-
-```bash
-$ go build -tags nosigning
-```
 
 ## Example
 
 This is just a code snippet. Please check the `examples` directory
 for more complete and ready to use examples.
 
 ```go
-// Instantiate the WebSocket transport.
-t, _ := websocket.NewTransport("ws://localhost:8090")
-
-// Use the transport to create an RPC client.
-client, _ := rpc.NewClient(t)
-defer client.Close()
-
-// Call "get_config".
-config, _ := client.Database.GetConfig()
-
-// Start processing blocks.
-lastBlock := 1800000
-for {
-	// Call "get_dynamic_global_properties".
-	props, _ := client.Database.GetDynamicGlobalProperties()
-
-	for props.LastIrreversibleBlockNum-lastBlock > 0 {
-		// Call "get_block".
-		block, _ := client.Database.GetBlock(lastBlock)
-
-		// Process the transactions.
-		for _, tx := range block.Transactions {
-			for _, op := range tx.Operations {
-				switch body := op.Data().(type) {
-					// Comment operation.
-					case *types.CommentOperation:
-						content, _ := client.Database.GetContent(body.Author, body.Permlink)
-						fmt.Printf("COMMENT @%v %v\n", content.Author, content.URL)
-
-					// Vote operation.
+	cls,_ := client.NewClient([]string{"ws://localhost:8090"},"steem")
+	defer cls.Close()
+
+	// Get config.
+	log.Println("---> GetConfig()")
+	config, err := cls.Database.GetConfig()
+	if err != nil {
+		return err
+	}
+
+	// Use the last irreversible block number as the initial last block number.
+	props, err := cls.Database.GetDynamicGlobalProperties()
+	if err != nil {
+		return err
+	}
+	lastBlock := props.LastIrreversibleBlockNum
+
+	// Keep processing incoming blocks forever.
+	log.Printf("---> Entering the block processing loop (last block = %v)\n", lastBlock)
+	for {
+		// Get current properties.
+		props, err := cls.Database.GetDynamicGlobalProperties()
+		if err != nil {
+			return err
+		}
+
+		// Process new blocks.
+		for props.LastIrreversibleBlockNum-lastBlock > 0 {
+			block, err := cls.Database.GetBlock(lastBlock)
+			if err != nil {
+				return err
+			}
+
+			// Process the transactions.
+			for _, tx := range block.Transactions {
+				for _, operation := range tx.Operations {
+					switch op := operation.Data().(type) {
 					case *types.VoteOperation:
-						fmt.Printf("VOTE @%v @%v/%v\n", body.Voter, body.Author, body.Permlink)
+						log.Printf("@%v voted for @%v/%v\n", op.Voter, op.Author, op.Permlink)
 
-					// You can add more cases, it depends on what
-					// operations you actually need to process.
+						// You can add more cases here, it depends on
+						// what operations you actually need to process.
+					}
 				}
 			}
+
+			lastBlock++
 		}
 
-		lastBlock++
+		// Sleep for STEEMIT_BLOCK_INTERVAL seconds before the next iteration.
+		time.Sleep(time.Duration(config.BlockInterval) * time.Second)
 	}
-
-	time.Sleep(time.Duration(config.SteemitBlockInterval) * time.Second)
-}
 ```
 
 ## Package Organisation
 
-You need to create a `Client` object to be able to do anything. To be able to
-instantiate a `Client`, you first need to create a transport to be used to
-execute RPC calls. The WebSocket transport is available in `transports/websocket`.
-Then you just need to call `NewClient(transport)`.
+
+You need to create a `Client` object to be able to do anything.
+Then you just need to call `NewClient()`.
 
 Once you create a `Client` object, you can start calling the methods exported
 via `steemd`'s RPC endpoint by invoking associated methods on the client object.
@@ -99,33 +88,6 @@ For example, to call `get_block` from `database_api`, you need to use
 When looking for a method to call, all you need is to turn the method name into
 CamelCase, e.g. `get_config` becomes `Client.Database.GetConfig`.
 
-### Raw and Full Methods
-
-There are two methods implemented for every method exported via the RPC endpoint.
-The regular version and the raw version. Let's see an example for `get_config`:
-
-```go
-func (client *Client) GetConfig() (*Config, error) {
-	...
-}
-
-func (client *Client) GetConfigRaw() (*json.RawMessage, error) {
-	...
-}
-```
-
-As we can see, the difference is that the raw version returns `*json.RawMessage`,
-so it is not trying to unmarshall the response into a properly typed response.
-
-There are two reasons for this:
-
-1. To be able to see raw data.
-2. To be able to call most of the remote methods even though the response
-   object is not yet known or specified.
-
-It is already benefitial to just have the raw version because at least
-the method parameters are statically typed.
-
 ## Status
 
 This package is still under rapid development and it is by no means complete.

diff --git a/api/README.md b/api/README.md
@@ -0,0 +1,99 @@
+# API
+
+This package adds support for `steem api`.
+
+## State
+
+| **ID** | **Command Name** | **Version** |
+| :-: | :-: | :-: |
+| **account_by_key** |
+| 1 | get_key_references | **RAW** |
+| **account_history** |
+| 1 | get_account_history | **DONE** |
+| **committee_api** |
+| 1 | get_committee_request | **DONE** |
+| 2 | get_committee_request_votes | **DONE** |
+| 3 | get_committee_requests_list | **DONE** |
+| **database_api** |
+| 1 | get_account_count | **DONE** |
+| 2 | get_accounts | **DONE** |
+| 3 | get_block | **DONE** |
+| 4 | get_block_header | **DONE** |
+| 5 | get_chain_properties | **DONE** |
+| 6 | get_config | **DONE** |
+| 7 | get_database_info | **DONE** |
+| 8 | get_dynamic_global_properties | **DONE** |
+| 9 | get_escrow | **DONE** |
+| 10 | get_expiring_vesting_delegations | **DONE** |
+| 11| get_hardfork_version | **DONE** |
+| 12| get_next_scheduled_hardfork | **DONE** |
+| 13 | get_owner_history | **DONE** |
+| 14 | get_potential_signatures | **DONE** |
+| 15 | get_proposed_transaction | **DONE** |
+| 16 | get_recovery_request | **DONE** |
+| 17 | get_required_signatures | **DONE** |
+| 18 | get_transaction_hex | **DONE** |
+| 19 | get_vesting_delegations | **DONE** |
+| 20 | get_withdraw_routes | **DONE** |
+| 21 | lookup_account_names | **DONE** |
+| 22 | lookup_accounts | **DONE** |
+| 23 | verify_account_authority | **DONE** |
+| 24 | verify_authority | **DONE** |
+| **follow** |
+| 1 | get_blog | **DONE** |
+| 2 | get_blog_authors | **DONE** |
+| 3 | get_blog_entries | **DONE** |
+| 4 | get_feed | **DONE** |
+| 5 | get_feed_entries | **DONE** |
+| 6 | get_follow_count | **DONE** |
+| 7 | get_followers | **DONE** |
+| 8 | get_following | **DONE** |
+| 9 | get_reblogged_by | **DONE** |
+| **invite_api** |
+| 1 | get_invites_list | **DONE** |
+| 2 | get_invite_by_id | **DONE** |
+| 3 | get_invite_by_key | **DONE** |
+| **network_broadcast_api** |
+| 1 | broadcast_block | **NONE** |
+| 2 | broadcast_transaction | **DONE** |
+| 3 | broadcast_transaction_synchronous | **DONE** |
+| 4 | broadcast_transaction_with_callback | **NONE** |
+| **operation_history** |
+| 1 | get_ops_in_block | **DONE** |
+| 2 | get_transaction | **DONE** |
+| **social_network** |
+| 1 | get_account_votes | **DONE** |
+| 2 | get_active_votes | **DONE** |
+| 3 | get_all_content_replies | **DONE** |
+| 4 | get_content | **DONE** |
+| 5 | get_content_replies | **DONE** |
+| 6 | get_replies_by_last_update | **DONE** |
+| **tags** |
+| 1 | get_discussions_by_active | **DONE** |
+| 2 | get_discussions_by_author_before_date | **DONE** |
+| 3 | get_discussions_by_blog | **DONE** |
+| 4 | get_discussions_by_cashout | **DONE** |
+| 5 | get_discussions_by_children | **DONE** |
+| 6 | get_discussions_by_contents | **DONE** |
+| 7 | get_discussions_by_created | **DONE** |
+| 8 | get_discussions_by_feed | **DONE** |
+| 9 | get_discussions_by_hot | **DONE** |
+| 10 | get_discussions_by_payout | **DONE** |
+| 11 | get_discussions_by_trending | **DONE** |
+| 12 | get_discussions_by_votes | **DONE** |
+| 13 | get_languages | **DONE** |
+| 14 | get_tags_used_by_author | **RAW** |
+| 15 | get_trending_tags | **DONE** |
+| **witness_api** |
+| 1 | get_active_witnesses | **DONE** |
+| 2 | get_miner_queue | **DONE** |
+| 3 | get_witness_by_account | **DONE** |
+| 4 | get_witness_count | **DONE** |
+| 5 | get_witness_schedule | **DONE** |
+| 6 | get_witnesses | **DONE** |
+| 7 | get_witnesses_by_vote | **DONE** |
+| 8 | lookup_witness_accounts | **DONE** |
+
+## License
+
+MIT, see the `LICENSE` file.
diff --git a/api/api.go b/api/api.go
@@ -0,0 +1,25 @@
+package api
+
+import (
+	"encoding/json"
+
+	"github.com/asuleymanov/steem-go/transports"
+)
+
+//API plug-in structure
+type API struct {
+	caller transports.Caller
+}
+
+//NewAPI plug-in initialization
+func NewAPI(caller transports.Caller) *API {
+	return &API{caller}
+}
+
+func (api *API) call(apiID string, method string, params, resp interface{}) error {
+	return api.caller.Call("call", []interface{}{apiID, method, params}, resp)
+}
+
+func (api *API) setCallback(apiID string, method string, callback func(raw json.RawMessage)) error {
+	return api.caller.SetCallback(apiID, method, callback)
+}