问团队机器人。"TypeError: source.on不是'createConversation‘方法中的函数“

EN

credentials = new MicrosoftAppCredentials(process.env.MicrosoftAppId, process.env.MicrosoftAppPassword);

connectorClient = new ConnectorClient(credentials, { baseUri: activity.serviceUrl });

MicrosoftAppCredentials.trustServiceUrl(activity.serviceUrl);

const teams = require('botbuilder-teams');

const adapter = new BotFrameworkAdapter({
  appId: process.env.MicrosoftAppId,
  appPassword: process.env.MicrosoftAppPassword
})
  .use(new teams.TeamsMiddleware())

const { ConnectorClient, MicrosoftAppCredentials } = require('botframework-connector');

async teamsProactiveMessage ( stepContext ) {
  const credentials = new MicrosoftAppCredentials(process.env.MicrosoftAppId, process.env.MicrosoftAppPassword);
  const connector = new ConnectorClient(credentials, { baseUri: stepContext.context.activity.serviceUrl });
  const roster = await connector.conversations.getConversationMembers(stepContext.context.activity.conversation.id);

  const parameters = {
    members: [
      {
        id: roster[0].id
      }
    ],
    channelData: {
      tenant: {
        id: roster[0].tenantId
      }
    }
  };

  const conversationResource = await connector.conversations.createConversation(parameters);
  const message = MessageFactory.text('This is a proactive message');
  await connector.conversations.sendToConversation(conversationResource.id, message);

  return stepContext.next();
}

this.onTurn(async (context, next) => {
  if (context.activity.channelId === 'msteams') {
    MicrosoftAppCredentials.trustServiceUrl(context.activity.serviceUrl);
  }
  await next();
});

// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.

const dotenv = require('dotenv');
const path = require('path');
const restify = require('restify');

// Import required bot services.
// See https://aka.ms/bot-services to learn more about the different parts of a bot.
const { BotFrameworkAdapter } = require('botbuilder');

// This bot's main dialog.
const { MyBot } = require('./bot');

// Import required bot configuration.
const ENV_FILE = path.join(__dirname, '.env');
dotenv.config({ path: ENV_FILE });

// Create HTTP server
const server = restify.createServer();
server.listen(process.env.port || process.env.PORT || 3978, () => {
    console.log(`\n${ server.name } listening to ${ server.url }`);
    console.log(`\nGet Bot Framework Emulator: https://aka.ms/botframework-emulator`);
    console.log(`\nTo test your bot, see: https://aka.ms/debug-with-emulator`);
});

// Create adapter.
// See https://aka.ms/about-bot-adapter to learn more about how bots work.
const adapter = new BotFrameworkAdapter({
    appId: process.env.MicrosoftAppId,
    appPassword: process.env.MicrosoftAppPassword
});

// Catch-all for errors.
adapter.onTurnError = async (context, error) => {
    // This check writes out errors to console log .vs. app insights.
    console.error(`\n [onTurnError]: ${ error }`);
    // Send a message to the user
    await context.sendActivity(`Oops. Something went wrong!`);
};

// Create the main dialog.
const myBot = new MyBot();

// Listen for incoming requests.
server.post('/api/messages', (req, res) => {
    adapter.processActivity(req, res, async (context) => {
        // Route to main dialog.
        await myBot.run(context);
    });
});

   const { ConnectorClient, MicrosoftAppCredentials, BotConnector } = require('botframework-connector');
   const { ActivityHandler } = require('botbuilder');

   class MyBot extends ActivityHandler {

    constructor() {
        super();
        // See https://aka.ms/about-bot-activity-message to learn more about the message and other activity types.
        this.onMessage(async (context, next) => {
            //await context.sendActivity(`You said '${context.activity.text}'`); // It works
            var activity = context.activity;
            await MicrosoftAppCredentials.trustServiceUrl(activity.serviceUrl);
            var connectorClient = new ConnectorClient(credentials, { baseUri: activity.serviceUrl });
            const parameters = {
                members: [{ id: activity.from.id }],
                isGroup: false,
                channelData:
                {
                    tenant: {
                        id: activity.conversation.tenantId
                    }
                }
            };
        var conversationResource = await connectorClient.conversations.createConversation(parameters);  

    });
}

module.exports.MyBot = MyBot;

 [onTurnError]: TypeError: source.on is not a function