blob: 5aa334048ad3207194f1b376fbe497eb3e0f3f4f [file] [log] [blame]
// Copyright 2021 The Chromium OS Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
// Package main implements the testservice server to listen to test and provision requests.
package main
import (
// TestServiceServer implement a server that will listen to test and provision requests.
type TestServiceServer struct {
Manager *lro.Manager
logger *log.Logger
// newTestServiceServer creates a new test service server to listen to test requests.
func newTestServiceServer(l net.Listener, logger *log.Logger) (*grpc.Server, error) {
s := &TestServiceServer{
Manager: lro.New(),
logger: logger,
defer s.Manager.Close()
server := grpc.NewServer()
api.RegisterTestServiceServer(server, s)
longrunning.RegisterOperationsServer(server, s.Manager)
logger.Println("testservice listen to request at ", l.Addr().String())
return server, nil
// RunTests runs the requested tests.
func (s *TestServiceServer) RunTests(ctx context.Context, req *api.RunTestsRequest) (*longrunning.Operation, error) {
s.logger.Println("Received api.RunTestsRequest: ", *req)
op := s.Manager.NewOperation()
s.Manager.SetResult(op.Name, &api.RunTestsResponse{})
return op, nil