goSam

package module
v0.32.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 8, 2019 License: MIT Imports: 14 Imported by: 18

README

goSam

A go library for using the I2P Simple Anonymous Messaging (SAM version 3.0) bridge. It has support for SAM version 3.1 signature types.

This is in an early development stage. I would love to hear about any issues or ideas for improvement.

Installation

go get github.com/eyedeekay/goSam

Using it for HTTP Transport

I implemented Client.Dial like net.Dial so you can use go's library packages like http.

package main

import (
	"io"
	"log"
	"net/http"
	"os"

	"github.com/cryptix/goSam"
)

func main() {
	// create a default sam client
	sam, err := goSam.NewDefaultClient()
	checkErr(err)

	log.Println("Client Created")

	// create a transport that uses SAM to dial TCP Connections
	tr := &http.Transport{
		Dial: sam.Dial,
	}

	// create  a client using this transport
	client := &http.Client{Transport: tr}

	// send a get request
	resp, err := client.Get("http://stats.i2p/")
	checkErr(err)
	defer resp.Body.Close()

	log.Printf("Get returned %+v\n", resp)

	// create a file for the response
	file, err := os.Create("stats.html")
	checkErr(err)
	defer file.Close()

	// copy the response to the file
	_, err = io.Copy(file, resp.Body)
	checkErr(err)

	log.Println("Done.")
}

func checkErr(err error) {
	if err != nil {
		log.Fatal(err)
	}
}
.deb package

A package for installing this on Debian is buildable, and a version for Ubuntu is available as a PPA and mirrored via i2p. To build the deb package, from the root of this repository with the build dependencies installed(git, i2p, go, debuild) run the command

    debuild -us -uc

to produce an unsigned deb for personal use only. For packagers,

    debuild -S

will produce a viable source package for use with Launchpad PPA's and other similar systems.

TODO
  • Implement STREAM ACCEPT and STREAM FORWARD
  • Implement datagrams (Repliable and Anon)

Documentation

Index

Constants

View Source 
const (
	ResultOk             = "OK"              //Operation completed successfully
	ResultCantReachPeer  = "CANT_REACH_PEER" //The peer exists, but cannot be reached
	ResultDuplicatedID   = "DUPLICATED_ID"   //If the nickname is already associated with a session :
	ResultDuplicatedDest = "DUPLICATED_DEST" //The specified Destination is already in use
	ResultI2PError       = "I2P_ERROR"       //A generic I2P error (e.g. I2CP disconnection, etc.)
	ResultInvalidKey     = "INVALID_KEY"     //The specified key is not valid (bad format, etc.)
	ResultKeyNotFound    = "KEY_NOT_FOUND"   //The naming system can't resolve the given name
	ResultPeerNotFound   = "PEER_NOT_FOUND"  //The peer cannot be found on the network
	ResultTimeout        = "TIMEOUT"         // Timeout while waiting for an event (e.g. peer answer)
)

The Possible Results send by SAM

Variables

View Source 
var SAMsigTypes = []string{
	"SIGNATURE_TYPE=DSA_SHA1",
	"SIGNATURE_TYPE=ECDSA_SHA256_P256",
	"SIGNATURE_TYPE=ECDSA_SHA384_P384",
	"SIGNATURE_TYPE=ECDSA_SHA512_P521",
	"SIGNATURE_TYPE=EdDSA_SHA512_Ed25519",
}

Functions

func SetAddr 

func SetAddr(s ...string) func(*Client) error

SetAddr sets a clients's address in the form host:port or host, port

func SetAddrMixed 

func SetAddrMixed(s string, i int) func(*Client) error

SetAddrMixed sets a clients's address in the form host, port(int)

func SetCloseIdle 

func SetCloseIdle(b bool) func(*Client) error

SetCloseIdle sets the tunnels to close after a specific amount of time

func SetCloseIdleTime 

func SetCloseIdleTime(u uint) func(*Client) error

SetCloseIdleTime sets the time in milliseconds to wait before closing tunnels

func SetCompression 

func SetCompression(b bool) func(*Client) error

SetCompression sets the tunnels to close after a specific amount of time

func SetDebug 

func SetDebug(b bool) func(*Client) error

SetDebug enables debugging messages

func SetEncrypt 

func SetEncrypt(b bool) func(*Client) error

SetEncrypt tells the router to use an encrypted leaseset

func SetFromPort 

func SetFromPort(s string) func(*Client) error

SetFromPort sets the port of the client's SAM bridge using a string

func SetFromPortInt 

func SetFromPortInt(i int) func(*Client) error

SetFromPortInt sets the port of the client's SAM bridge using a string

func SetHost 

func SetHost(s string) func(*Client) error

SetHost sets the host of the client's SAM bridge

func SetInBackups 

func SetInBackups(u uint) func(*Client) error

SetInBackups sets the inbound tunnel backups

func SetInLength 

func SetInLength(u uint) func(*Client) error

SetInLength sets the number of hops inbound

func SetInQuantity 

func SetInQuantity(u uint) func(*Client) error

SetInQuantity sets the inbound tunnel quantity

func SetInVariance 

func SetInVariance(i int) func(*Client) error

SetInVariance sets the variance of a number of hops inbound

func SetLocalDestination 

func SetLocalDestination(s string) func(*Client) error

SetLocalDestination sets the local destination of the tunnel from a private key

func SetOutBackups 

func SetOutBackups(u uint) func(*Client) error

SetOutBackups sets the inbound tunnel backups

func SetOutLength 

func SetOutLength(u uint) func(*Client) error

SetOutLength sets the number of hops outbound

func SetOutQuantity 

func SetOutQuantity(u uint) func(*Client) error

SetOutQuantity sets the outbound tunnel quantity

func SetOutVariance 

func SetOutVariance(i int) func(*Client) error

SetOutVariance sets the variance of a number of hops outbound

func SetPort 

func SetPort(s string) func(*Client) error

SetPort sets the port of the client's SAM bridge using a string

func SetPortInt 

func SetPortInt(i int) func(*Client) error

SetPortInt sets the port of the client's SAM bridge using a string

func SetReduceIdle 

func SetReduceIdle(b bool) func(*Client) error

SetReduceIdle sets the created tunnels to be reduced during extended idle time to avoid excessive resource usage

func SetReduceIdleQuantity 

func SetReduceIdleQuantity(u uint) func(*Client) error

SetReduceIdleQuantity sets number of tunnels to keep alive during an extended idle period

func SetReduceIdleTime 

func SetReduceIdleTime(u uint) func(*Client) error

SetReduceIdleTime sets time to wait before the tunnel quantity is reduced

func SetSignatureType 

func SetSignatureType(s string) func(*Client) error

SetSignatureType tells gosam to pass SAM a signature_type parameter with one of the following values: 

"SIGNATURE_TYPE=DSA_SHA1",
"SIGNATURE_TYPE=ECDSA_SHA256_P256",
"SIGNATURE_TYPE=ECDSA_SHA384_P384",
"SIGNATURE_TYPE=ECDSA_SHA512_P521",
"SIGNATURE_TYPE=EdDSA_SHA512_Ed25519",

or an empty string

func SetToPort 

func SetToPort(s string) func(*Client) error

SetToPort sets the port of the client's SAM bridge using a string

func SetToPortInt 

func SetToPortInt(i int) func(*Client) error

SetToPortInt sets the port of the client's SAM bridge using a string

func SetUnpublished 

func SetUnpublished(b bool) func(*Client) error

SetUnpublished tells the router to not publish the client leaseset

Types

type Client 

type Client struct {
	SamConn net.Conn
	// contains filtered or unexported fields
}

A Client represents a single Connection to the SAM bridge

func NewClient 

func NewClient(addr string) (*Client, error)

NewClient creates a new client, connecting to a specified port

func NewClientFromOptions 

func NewClientFromOptions(opts ...func(*Client) error) (*Client, error)

NewClientFromOptions creates a new client, connecting to a specified port

func NewDefaultClient 

func NewDefaultClient() (*Client, error)

NewDefaultClient creates a new client, connecting to the default host:port at localhost:7656

func (*Client) Accept 

func (c *Client) Accept() (net.Conn, error)

Accept accepts a connection on a listening goSam.Client(Implements net.Listener) or, if the connection isn't listening yet, just calls AcceptI2P for compatibility with older versions.

func (*Client) AcceptI2P 

func (c *Client) AcceptI2P() (net.Conn, error)

AcceptI2P creates a new Client and accepts a connection on it

func (*Client) Addr 

func (p *Client) Addr() net.Addr

func (*Client) Base32 

func (c *Client) Base32() string

Base32 returns the base32 of the local tunnel

func (*Client) Base64 

func (c *Client) Base64() string

Base64 returns the base64 of the local tunnel

func (*Client) Close 

func (c *Client) Close() error

Close the underlying socket to SAM

func (*Client) CreateStreamSession 

func (c *Client) CreateStreamSession(id int32, dest string) (string, error)

CreateStreamSession creates a new STREAM Session. Returns the Id for the new Client.

func (*Client) Destination 

func (c *Client) Destination() string

Destination returns the full destination of the local tunnel

func (*Client) Dial 

func (c *Client) Dial(network, addr string) (net.Conn, error)

Dial implements the net.Dial function and can be used for http.Transport

func (*Client) DialContext 

func (c *Client) DialContext(ctx context.Context, network, addr string) (net.Conn, error)

DialContext implements the net.DialContext function and can be used for http.Transport

func (*Client) ID 

func (p *Client) ID() string

func (*Client) Listen 

func (c *Client) Listen() (net.Listener, error)

Listen creates a new Client and returns a net.listener which *must* be started with Accept

func (*Client) ListenI2P 

func (c *Client) ListenI2P(dest string) (net.Listener, error)

ListenI2P creates a new Client and returns a net.listener which *must* be started with Accept

func (*Client) Lookup 

func (c *Client) Lookup(name string) (string, error)

Lookup askes SAM for the internal i2p address from name

func (*Client) NewClient 

func (c *Client) NewClient() (*Client, error)

NewClient generates an exact copy of the client with the same options

func (*Client) NewID 

func (c *Client) NewID() int32

NewID generates a random number to use as an tunnel name

func (*Client) Print 

func (c *Client) Print() string

Print return all options as string

func (*Client) StreamAccept 

func (c *Client) StreamAccept(id int32) (*Reply, error)

StreamAccept asks SAM to accept a TCP-Like connection

func (*Client) StreamConnect 

func (c *Client) StreamConnect(id int32, dest string) error

StreamConnect asks SAM for a TCP-Like connection to dest, has to be called on a new Client

type Option 

type Option func(*Client) error

Option is a client Option

type Reply 

type Reply struct {
	Topic string
	Type  string

	Pairs map[string]string
}

Reply is the parsed result of a SAM command, containing a map of all the key-value pairs

type ReplyError 

type ReplyError struct {
	Result string
	Reply  *Reply
}

A ReplyError is a custom error type, containing the Result and full Reply

func (ReplyError) Error 

func (r ReplyError) Error() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.