node_impl.go

/*
Copyright IBM Corp. 2016 All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

		 http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package crypto

import (
	"crypto/ecdsa"
	"crypto/x509"

	"github.com/TarantulaTechnology/fabric/core/crypto/primitives"
	"github.com/TarantulaTechnology/fabric/core/crypto/utils"
)

// Public Struct

type nodeImpl struct {
	isInitialized bool

	// Node type
	eType NodeType

	// Configuration
	conf *configuration

	// keyStore
	ks *keyStore

	// Certs Pool
	rootsCertPool *x509.CertPool
	tlsCertPool   *x509.CertPool
	ecaCertPool   *x509.CertPool
	tcaCertPool   *x509.CertPool

	// 48-bytes identifier
	id []byte

	// Enrollment Certificate and private key
	enrollID       string
	enrollCert     *x509.Certificate
	enrollPrivKey  *ecdsa.PrivateKey
	enrollCertHash []byte

	// Enrollment Chain
	enrollChainKey interface{}

	// TLS
	tlsCert *x509.Certificate

	// Crypto SPI
	eciesSPI primitives.AsymmetricCipherSPI
}

func (node *nodeImpl) GetType() NodeType {
	return node.eType
}

func (node *nodeImpl) GetName() string {
	return node.conf.name
}

func (node *nodeImpl) isRegistered() bool {
	missing, _ := utils.FileMissing(node.conf.getRawsPath(), node.conf.getEnrollmentIDFilename())

	return !missing
}

func (node *nodeImpl) register(eType NodeType, name string, pwd []byte, enrollID, enrollPWD string) error {
	if node.isInitialized {
		return utils.ErrAlreadyInitialized
	}

	// Set entity type
	node.eType = eType

	// Init Conf
	if err := node.initConfiguration(name); err != nil {
		node.Errorf("Failed initiliazing configuration [%s]: [%s].", enrollID, err)

		return err
	}

	// Start registration
	if node.isRegistered() {
		return utils.ErrAlreadyRegistered
	}

	node.Debugf("Registering node [%s]...", enrollID)

	// Initialize keystore
	err := node.initKeyStore(pwd)
	if err != nil {
		if err != utils.ErrKeyStoreAlreadyInitialized {
			node.Error("Keystore already initialized.")
		} else {
			node.Errorf("Failed initiliazing keystore [%s].", err.Error())

			return err
		}
	}

	// Register crypto engine
	err = node.registerCryptoEngine(enrollID, enrollPWD)
	if err != nil {
		node.Errorf("Failed registering node crypto engine [%s].", err.Error())
		return err
	}

	node.Debugf("Registering node [%s]...done!", enrollID)

	return nil
}

func (node *nodeImpl) init(eType NodeType, name string, pwd []byte) error {
	if node.isInitialized {
		node.Error("Already initializaed.")

		return utils.ErrAlreadyInitialized
	}

	// Set entity type
	node.eType = eType

	// Init Conf
	if err := node.initConfiguration(name); err != nil {
		return err
	}

	if !node.isRegistered() {
		node.Error("Not registered yet.")

		return utils.ErrRegistrationRequired
	}

	// Initialize keystore
	node.Debug("Init keystore...")
	err := node.initKeyStore(pwd)
	if err != nil {
		if err != utils.ErrKeyStoreAlreadyInitialized {
			node.Error("Keystore already initialized.")
		} else {
			node.Errorf("Failed initiliazing keystore [%s].", err.Error())

			return err
		}
	}
	node.Debug("Init keystore...done.")

	// Init crypto engine
	err = node.initCryptoEngine()
	if err != nil {
		node.Errorf("Failed initiliazing crypto engine [%s].", err.Error())
		return err
	}

	// Initialisation complete
	node.isInitialized = true

	node.Debug("Initialization...done.")

	return nil
}

func (node *nodeImpl) close() error {
	// Close keystore
	var err error

	if node.ks != nil {
		err = node.ks.close()
	}

	return err
}