Only the 'private' psi is supported by the default private state manager

[MisiakGeo]

Hello all,
I am trying to call a smart contract function using GO, that produced by Abigen, and I am using websocket to connect to the goQuorum Node. Now I am using a HTTP connection to submit transaction and a Websocket connection to receive events. I am aware that websockets can provide the freedom to submit or call functions from a smart contract.

While I am able to receive events from websocket, when I am trying to make a call or a transaction from websocket, I receive the error "Only the 'private' psi is supported by the default private state manager"

The Go code snippet that I am using to connect is the following:

var (
 goQuorumNodeWSURL               string = "wss://localhost:8545/?PSI="
)

func connectToGoQuorumNodeWS(ctx context.Context, url string, rootCA string) (*rpc.Client, error) {
 cert, err := os.ReadFile(rootCA)
 if err != nil {
  return nil, fmt.Errorf("Couldn't load file: ", err.Error())
 }
 certPool := x509.NewCertPool()
 if !certPool.AppendCertsFromPEM(cert) {
  return nil, fmt.Errorf("Couldn't append certs to CertPool: ", err.Error())
 }       
 tlsClientConfig := &tls.Config{
    RootCAs: certPool,
 }
 client, err := rpc.DialWebsocketWithCustomTLS(ctx, url, "", tlsClientConfig)
 if err != nil {
  return nil, fmt.Errorf("Could not connect to goQuorum Node: ", err.Error())
 }
 return client, nil
}

// RequestHydraToken functin requests a refreshed access token from the Hydra server.
func requestHydraToken(tokenURL string, clientId string, clientSecret string, audience string, rootCA string) (string, error) {
 ctx := context.Background()	
 hydraCert, err := os.ReadFile(rootCA)
 if err != nil {
  return "", fmt.Errorf("Couldn't load file: ", err.Error())
 }
 
 hydraCertPool := x509.NewCertPool()
 if !hydraCertPool.AppendCertsFromPEM(hydraCert) {
  return "", fmt.Errorf("Couldn't append certs to CertPool: ", err.Error())
 }
 
 httpHydraClient := &http.Client{
  Timeout:   5 * time.Second,
  Transport: &http.Transport{
   IdleConnTimeout: 10 * time.Second,
   TLSClientConfig: &tls.Config{
    RootCAs: hydraCertPool,
   },
  },
 }
 
 conf := &clientcredentials.Config{
  TokenURL: tokenURL,
  ClientID: clientId,
  ClientSecret: clientSecret,
  Scopes: []string{"rpc://rpc_modules", "rpc://eth_*", "rpc://admin_nodeInfo"},
  EndpointParams: url.Values{"audience": { audience }},
 }
 
 token ,err := conf.Token(context.WithValue(ctx, oauth2.HTTPClient, httpHydraClient))
 if err != nil {
  return "", fmt.Errorf("Couldn't refresh token", err.Error())
 }
 return "Bearer " + token.AccessToken, nil
}

// Main function
func main() {
 // Refresh Token
 var f rpc.HttpCredentialsProviderFunc = func(ctx context.Context) (string, error) {
  token, err := requestHydraToken(tokenURL, clientId, clientSecret, audience, RootCertificateHydraPath)
  if err != nil {
   warn("main", "Fail to request Token from Hydra: " + err.Error())
   os.Exit(1)
  }
  return token, nil
 }
 
 // Connect to goQuorum Node WS
 ctx := rpc.WithCredentialsProvider(context.Background(), f)
 goQuorumClientWS, err := connectToGoQuorumNodeWS(ctx, goQuorumNodeWSURL + clientId, RootCertificateGoQuorumNodePath)
 if err != nil {
    warn("main", "Fail to connect to WebSocket GoQuorum Node: " + err.Error())
    os.Exit(1)
 }
 defer goQuorumClientWS.Close()
 
 ethereumClient := ethClient.NewClientWithPTM(goQuorumClientWS, nil)
 defer ethereumClient.Close()
 
// Create new Test instance
 newTest, err := testSDK.NewTest(common.HexToAddress(<SC Address>), ethereumClient)
 if err != nil {
  warn("main", "Fail to Create a new Test Instance: " + err.Error())
  os.Exit(1)
 }
}

When newTest is used to perform a call or a transaction, I receive the aforementioned error. How can I overcome this?

[antonydenyer]

You only need to use PSI for multi-tenancy - what the error is saying is that there's only one private state.

[MisiakGeo]

Thank you very much. It is indeed strange because the HTTP server allows me to do the same thing but websocket does not.