Moving BBSim entrypoint in the cmd folder, building bbsimctl in the container
Change-Id: I4823578ed17c40b13c1c9a561e7aa7e6640f7f19
diff --git a/internal/bbsim/api/grpc_api_server.go b/internal/bbsim/api/grpc_api_server.go
new file mode 100644
index 0000000..27b0ce5
--- /dev/null
+++ b/internal/bbsim/api/grpc_api_server.go
@@ -0,0 +1,104 @@
+/*
+ * Copyright 2018-present Open Networking Foundation
+
+ * 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 api
+
+import (
+ "context"
+ "github.com/opencord/bbsim/api/bbsim"
+ "github.com/opencord/bbsim/internal/bbsim/devices"
+ log "github.com/sirupsen/logrus"
+)
+
+var logger = log.WithFields(log.Fields{
+ "module": "GrpcApiServer",
+})
+
+var (
+ version string
+ buildTime string
+ commitHash string
+ gitStatus string
+)
+
+type BBSimServer struct {
+}
+
+func (s BBSimServer) Version(ctx context.Context, req *bbsim.Empty) (*bbsim.VersionNumber, error) {
+ // TODO add a flag to specofy whether the tree was clean at this commit or not
+ return &bbsim.VersionNumber{
+ Version: version,
+ BuildTime: buildTime,
+ CommitHash: commitHash,
+ GitStatus: gitStatus,
+ }, nil
+}
+
+func (s BBSimServer) GetOlt(ctx context.Context, req *bbsim.Empty) (*bbsim.Olt, error) {
+ olt := devices.GetOLT()
+ nnis := []*bbsim.NNIPort{}
+ pons := []*bbsim.PONPort{}
+
+ for _, nni := range olt.Nnis {
+ n := bbsim.NNIPort{
+ ID: int32(nni.ID),
+ OperState: nni.OperState.Current(),
+ }
+ nnis = append(nnis, &n)
+ }
+
+ for _, pon := range olt.Pons {
+ p := bbsim.PONPort{
+ ID: int32(pon.ID),
+ OperState: pon.OperState.Current(),
+ }
+ pons = append(pons, &p)
+ }
+
+ res := bbsim.Olt{
+ ID: int32(olt.ID),
+ SerialNumber: olt.SerialNumber,
+ OperState: olt.OperState.Current(),
+ InternalState: olt.InternalState.Current(),
+ NNIPorts: nnis,
+ PONPorts: pons,
+ }
+ return &res, nil
+}
+
+func (s BBSimServer) GetONUs(ctx context.Context, req *bbsim.Empty) (*bbsim.ONUs, error) {
+ olt := devices.GetOLT()
+ onus := bbsim.ONUs{
+ Items: []*bbsim.ONU{},
+ }
+
+ for _, pon := range olt.Pons {
+ for _, o := range pon.Onus {
+ onu := bbsim.ONU{
+ ID: int32(o.ID),
+ SerialNumber: o.Sn(),
+ OperState: o.OperState.Current(),
+ InternalState: o.InternalState.Current(),
+ PonPortID: int32(o.PonPortID),
+ STag: int32(o.STag),
+ CTag: int32(o.CTag),
+ HwAddress: o.HwAddress.String(),
+ }
+ onus.Items = append(onus.Items, &onu)
+ }
+ }
+ return &onus, nil
+}