function clientStreamingEcho(call, callback) {
const incomingTimestamps = call.metadata.get('timestamp');
if (incomingTimestamps.length > 0) {
console.log('Timestamp from metadata:');
for (const [index, value] of incomingTimestamps.entries()) {
console.log(` ${index}. ${value}`);
}
}
let lastReceivedMessage = '';
call.on('data', value => {
console.log(`Received request ${JSON.stringify(value)}`);
lastReceivedMessage = value.message;
});
call.on('end', () => {
console.log("Call end!")
const outgoingTrailers = new grpc.Metadata();
outgoingTrailers.set('timestamp', new Date().toISOString());
callback(null, {message: lastReceivedMessage}, outgoingTrailers);
});
}