import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
private List<SlackMessagePosted> getLastWeeksMessages() {
    SlackSession slackSession = getSlackSession();

    SlackChannel slackChannel = slackSession.findChannelByName("publicaties");

    ChannelHistoryModule channelHistoryModule = ChannelHistoryModuleFactory.createChannelHistoryModule(slackSession);

    List<SlackMessagePosted> lastWeeksMesages = IntStream.of(7, 6, 5, 4, 3, 2, 1)
            .mapToObj(daysAgo -> LocalDate.now().minus(daysAgo, ChronoUnit.DAYS))
            .flatMap(date -> getMessagesOfDay(slackChannel, channelHistoryModule, date))
            .collect(toList());

    try {
        slackSession.disconnect();
    } catch (Exception ex) {
        throw new RuntimeException(ex);
    }

    return lastWeeksMesages;
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
private String generatePost(final List<SlackMessagePosted> publicaties) {
    String content = "";

    content += "Hieronder is de lijst met #publicaties van deze week (" + WeekUtil.getWeekNumber() + ") te vinden. Veel leesplezier!";

    content += System.lineSeparator();

    content += IntStream.range(0, publicaties.size())
            .mapToObj(index -> (index + 1) + ". " + messageParser.parse(publicaties.get(index).getMessageContent()))
            .reduce("", (identity, accu) -> identity + System.lineSeparator() + accu);

    content += System.lineSeparator() + System.lineSeparator();

    String publicators = publicaties.stream()
            .map(message -> message.getSender().getUserName())
            .distinct()
            .reduce((identity, accu) -> identity + ", @" + accu).get();

    content += "De lijst is deze week mogelijk gemaakt door @" + publicators + ". Bedankt!";
    content += System.lineSeparator() + System.lineSeparator();
    content += "Kom je een interessante publicatie (foto/video/textueel) tegen? Deel deze dan in het #publicaties kanaal zodat iedereen er van kan leren :slightly_smiling_face:";
    content += System.lineSeparator() + System.lineSeparator();
    content += "Nog een fijne zondag!";

    return content;
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
private FirehoseMessage getImageFromIntegrations(IAdapter service, SlackMessagePosted event) {
  SlackAttachment attachment = event.getAttachments().get(0);

  String userName = event.getSender().getUserName();

  if(!userName.equals("RightGIF") && !userName.equals("ZOMG Memes!")) {
    return null;
  }

  return new FirehoseMessage(
      "slack",
      "post",
      userName,
      service.getIdentifier(),
      event.getChannel().getName(),
      attachment.getImageUrl()
  );
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void run(WatchWordBot bot, SlackMessagePosted event,
		LinkedList<String> args, SlackSession session) {
	if (args.isEmpty()) {
		fireIncorrectUsage();
		return;
	}

	String banishedWord = args.pop();

	boolean match = bot.getWordGenerator().isWordPresent(banishedWord);

	if (!match) {
		session.sendMessage(event.getChannel(), "'" + banishedWord
				+ "' not found in wordlist.");
		return;
	}

	session.sendMessage(event.getChannel(),
			"Banish command not implemented.");

}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void run(WatchWordBot bot, SlackMessagePosted event,
		LinkedList<String> args, SlackSession session) {
	SlackUser newUser = event.getSender();
	if (!bot.getLobby().hasUser(newUser)) {
		bot.getLobby().addUser(newUser);
		session.sendMessage(bot.getCurrentChannel(),
				WatchWordBot.getUsernameString(event.getSender())
						+ " has joined the game!");
		session.sendMessage(bot.getCurrentChannel(), bot.printFactions());
		bot.printMatchQuality();

	} else {
		session.sendMessage(event.getChannel(),
				WatchWordBot.getUsernameString(event.getSender())
						+ ", you're already in the game!");
	}
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void run(WatchWordBot bot, SlackMessagePosted event,
		LinkedList<String> args, SlackSession session) {
	int penaltyAmount = 0;

	if (!args.isEmpty()) {
		try {
			penaltyAmount = Integer.parseInt(args.pop());
			if (penaltyAmount < 0) {
				throw new IllegalArgumentException(
						"Penalty severity must be >= 0");
			}
		} catch (Exception e) {
			bot.printUsage(event.getChannel(), this.getPrimaryAlias()
					+ " <severity(0+)>");
			return;
		}
	}

	bot.penalizeCurrentFaction(penaltyAmount);
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void run(WatchWordBot bot, SlackMessagePosted event,
		LinkedList<String> args, SlackSession session) {
	if (bot.getGameState() == GameState.GAME) {
		session.sendMessage(
				bot.getCurrentChannel(),
				"Game has been canceled by "
						+ WatchWordBot.getUsernameString(event.getSender()));
		bot.partialGameReset();
		session.sendMessage(bot.getCurrentChannel(), bot.printFactions());
	} else {
		session.sendMessage(
				bot.getCurrentChannel(),
				"Lobby has been canceled by "
						+ WatchWordBot.getUsernameString(event.getSender()));
		bot.fullGameReset();
	}
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void run(WatchWordBot bot, SlackMessagePosted event,
		LinkedList<String> args, SlackSession session) {
	if (args.isEmpty()) {
		bot.printUsage(event.getChannel(),
				"[kick|remove] <player1, player2, ...>");
		return;
	}
	while (!args.isEmpty()) {
		String username = args.pop();
		SlackUser user = bot.getLobby().findUserByUsername(username);
		if (user != null) {
			bot.getLobby().removeUser(user);
			session.sendMessage(bot.getCurrentChannel(),
					event.getSender().getUserName() + " removed "
							+ WatchWordBot.getUsernameString(user));
		} else {
			session.sendMessage(bot.getCurrentChannel(),
					"Could not find user already in game with username '"
							+ username + "'.");
		}
	}
	session.sendMessage(bot.getLobby().getChannel(), bot.printFactions());
	bot.printMatchQuality();
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void run(WatchWordBot bot, SlackMessagePosted event,
		LinkedList<String> args, SlackSession session) {

	if (bot.getGame().getActingFaction() == null) {
		session.sendMessage(event.getChannel(),
				"Game is currently in an invalid state, there is currently no acting faction!");
		return;
	}
	CompetitiveTime time = bot.getGame().getRemainingTime();
	if (time == null) {
		session.sendMessage(event.getChannel(),
				"There is currently no timer enabled for the "
						+ bot.getGame().getActingFaction().getName()
						+ " team.");
		return;
	}
	session.sendMessage(event.getChannel(),
			"Remaining time for the "
					+ bot.getGame().getActingFaction().getName()
					+ " team: " + time.getTime(TimeUnit.SECONDS)
					+ " secs. (" + time.getOvertime(TimeUnit.SECONDS)
					+ " secs. of overtime)");
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void run(WatchWordBot bot, SlackMessagePosted event,
		LinkedList<String> args, SlackSession session) {
	if (bot.getLobby().getPlayer(event.getSender()) == null) {
		session.sendMessage(event.getChannel(),
				WatchWordBot.getUsernameString(event.getSender())
						+ ", you are currently not in this game!");
		return;
	}
	if (args.isEmpty()) {
		bot.printUsage(event.getChannel(), "guess <word>");
		return;
	}

	String wordBeingGuessed = args.pop();
	bot.makeGuess(wordBeingGuessed, session, event.getChannel(),
			event.getSender());
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
private synchronized void handleCommand(SlackMessagePosted event,
		SlackSession session) {
	updateLastIssuedCommandTime();
	LinkedList<String> args = new LinkedList<String>();
	args.addAll(Arrays.asList(event.getMessageContent().split("\\s+")));// event.getMessageContent().split(" ");

	boolean matchingPrefix = true;
	if (DEBUG) {
		String debugPrefix = args.pop().toLowerCase();
		matchingPrefix = debugPrefix.equals("d");
	}

	if (matchingPrefix) {
		String commandText = args.pop().toLowerCase();
		List<Command> commands = generateCommands(event, args, session);
		Command matchingCommand = findMatchingCommand(commandText, args,
				commands, event.getChannel());
		if (matchingCommand != null) {
			matchingCommand.run(this, event, args, session);
		}
	} else {
		handlePlainTextMessage(event, session);
	}
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
public List<Command> generateCommands(final SlackMessagePosted event,
		final LinkedList<String> args, final SlackSession session) {
	List<Command> commands = new ArrayList<Command>();
	commands.add(new BanishCommand());
	commands.add(new BotCommand());
	commands.add(new CancelCommand());
	commands.add(new ClueCommand());
	commands.add(new DefineCommand());
	commands.add(new EndCommand());
	commands.add(new FeatCommand());
	commands.add(new GridCommand());
	commands.add(new GuessCommand());
	commands.add(new HelpCommand());
	commands.add(new JoinCommand());
	commands.add(new KickCommand());
	commands.add(new ListCommand());
	commands.add(new LobbyCommand());
	commands.add(new PenaltyCommand());
	commands.add(new StartCommand());
	commands.add(new SwapCommand());
	commands.add(new SyncCommand());
	commands.add(new TimeCommand());
	commands.add(new WinCommand());
	return commands;
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void onEvent(
    final SlackMessagePosted event, final SlackSession session
) {
    final String channel = event.getChannel().getId();
    if (this.channel.equals(channel)) {
        final User user = new User.UserBuilder().withSlackNick(
            event.getSender().getUserName()
        ).build();
        final List<String> codes = Stream.of(
            event.getMessageContent().split("\n")
        ).filter(
            code -> this.progress.codes().contains(code)
        ).collect(Collectors.toList());
        if (!codes.isEmpty()) {
            this.progress.markProgressDone(user, codes.toArray(
                new String[codes.size()])
            );
            this.progress.reactToUserCodes(event.getTimeStamp(), channel);
        }
    }
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
/**
 * ProgressSlackChannel can mark codes done with service.
 */
@Test
public void marksProgressDoneIfMatchesCodes() throws Exception {
    final ProgressService service = Mockito.mock(ProgressService.class);
    final String id = "D0FUQEQUF";
    final ProgressSlackChannel channel = new ProgressSlackChannel(
        id, service
    );
    Mockito.when(service.codes()).thenReturn(
        new HashSet<>(Arrays.asList(
            "+code1", "+code2"
        ))
    );
    final String user = "juja";
    final SlackMessagePosted message = this.createMessageWithUserAndChannel(
        id, user, "+code2\n+code3\n+code1"
    );
    channel.onEvent(message, Mockito.mock(SlackSession.class));
    Mockito.verify(service).markProgressDone(
        new User.UserBuilder().withSlackNick(user).build(),
        "+code2", "+code1"
    );
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
/**
 * ProgressSlackChannel can filter channel.
 */
@Test
public void filtersChannel() throws Exception {
    final ProgressService service = Mockito.mock(ProgressService.class);
    final ProgressSlackChannel channel = new ProgressSlackChannel(
        "D0FUQEQUF", service
    );
    Mockito.when(service.codes()).thenReturn(
        new HashSet<>(Arrays.asList(
            "+code1", "+code2"
        ))
    );
    final String user = "juja";
    final SlackMessagePosted message = this.createMessageWithUserAndChannel(
        "AnotherChannelId", user, "+code2\n+code3\n+code1"
    );
    channel.onEvent(message, Mockito.mock(SlackSession.class));
    Mockito.verify(service, Mockito.never()).markProgressDone(
        new User.UserBuilder().withSlackNick(user).build(),
        "+code2", "+code1"
    );
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
/**
 * ProgressSlackChannel can reacts to user messages.
 */
@Test
public void reactsToMessage() throws Exception {
    final ProgressService service = Mockito.mock(ProgressService.class);
    final String chnl = "ProgressChannel";
    final ProgressSlackChannel channel = new ProgressSlackChannel(
        chnl, service
    );
    Mockito.when(service.codes()).thenReturn(
        new HashSet<>(Arrays.asList(
            "+code1", "+code2"
        ))
    );
    final String user = "juja";
    final SlackMessagePosted message = this.createMessageWithUserAndChannel(
        chnl, user, "+code2\n+code3\n+code1"
    );
    final String msg = "messageId";
    Mockito.when(message.getTimeStamp()).thenReturn(msg);
    channel.onEvent(message, Mockito.mock(SlackSession.class));
    Mockito.verify(service).reactToUserCodes(msg, chnl);
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
/**
 * ProgressSlackChannel doesn't react to message when no codes.
 */
@Test
public void doesNotReactToMessageWhenNoCodes() throws Exception {
    final ProgressService service = Mockito.mock(ProgressService.class);
    final String chnl = "ProgressChannel";
    final ProgressSlackChannel channel = new ProgressSlackChannel(
        chnl, service
    );
    Mockito.when(service.codes()).thenReturn(
        new HashSet<>(Arrays.asList(
            "+code1", "+code2"
        ))
    );
    final String user = "juja";
    final SlackMessagePosted message = this.createMessageWithUserAndChannel(
        chnl, user, "+invalidCode"
    );
    channel.onEvent(message, Mockito.mock(SlackSession.class));
    Mockito.verify(service, Mockito.never()).reactToUserCodes(
        Matchers.anyObject(), Matchers.anyObject()
    );
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public List<SlackMessagePosted> fetchHistoryOfChannel(String channelId, LocalDate day, int numberOfMessages) {
    Map<String, String> params = new HashMap<>();
    params.put("channel", channelId);
    if (day != null) {
        ZonedDateTime start = ZonedDateTime.of(day.atStartOfDay(), ZoneId.of("UTC"));
        ZonedDateTime end = ZonedDateTime.of(day.atStartOfDay().plusDays(1).minus(1, ChronoUnit.MILLIS), ZoneId.of("UTC"));
        params.put("oldest", convertDateToSlackTimestamp(start));
        params.put("latest", convertDateToSlackTimestamp(end));
    }
    if (numberOfMessages > -1) {
        params.put("count", String.valueOf(numberOfMessages));
    } else {
        params.put("count", String.valueOf(1000));
    }
    return fetchHistoryOfChannel(params);
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@Override
public void onEvent(ReactionRemoved event, SlackSession session) {
    String emojiName = event.getEmojiName();
    for (SlackMessagePosted message : messages) {
        for (String reaction : message.getReactions().keySet()) {
            if (emojiName.equals(reaction)) {
                int count = message.getReactions().get(emojiName);
                if (count == 1) {
                    message.getReactions().remove(emojiName);
                } else {
                    message.getReactions().put(emojiName, --count);
                }
                return;
            }
        }
    }
}
 

import com.ullink.slack.simpleslackapi.events.SlackMessagePosted; //导入依赖的package包/类
@PostConstruct
public void afterPropertiesSet(){
	slackSession.addMessagePostedListener( (SlackMessagePosted event, SlackSession session) -> {
		// don't pay any attention to messages we sent to avoid infinite loops
		if(!event.getSender().getId().equals(session.sessionPersona().getId())){
			if(StringUtils.startsWithIgnoreCase(event.getMessageContent(),"<@" + session.sessionPersona().getId() + ">")){
				// the message is addressed to this bot
				String message = event.getMessageContent().substring(session.sessionPersona().getId().length()+3);
				if(message.startsWith(":")){
					message = message.substring(1);
				}
				message = message.trim();
				session.sendMessage(event.getChannel(), slackMessageService.respondToMessage(Optional.of(event.getSender()), message), null);
			}else if(event.getChannel().isDirect()){
				// this is a direct message, so the bot should reply
				session.sendMessage(event.getChannel(), slackMessageService.respondToMessage(Optional.of(event.getSender()), event.getMessageContent()), null);
			}else if(StringUtils.containsIgnoreCase(event.getMessageContent(),"<@" + session.sessionPersona().getId() + ">")){
				// this bot is mentioned, so it should say something
				session.sendMessage(event.getChannel(), "How can I help you? You can send messages to @" + session.sessionPersona().getUserName() +  " or open a direct message chat. For help, say '@" + session.sessionPersona().getUserName() +  "' or send a direct message with the text 'help'", null);
			}
		}
	});
}