| | |
| | | |
| | | result = self.processor.is_valid_group_message(callback_data) |
| | | assert result is False |
| | | |
| | | @patch('app.services.message_processor.friend_ignore_service') |
| | | def test_is_valid_group_message_friend_ignored(self, mock_friend_ignore_service): |
| | | """测试好友在忽略列表中的消息""" |
| | | mock_friend_ignore_service.is_friend_ignored.return_value = True |
| | | |
| | | callback_data = { |
| | | "messageType": "80001", |
| | | "data": { |
| | | "fromUser": "wxid_test123", |
| | | "fromGroup": "group123@chatroom", |
| | | "content": "测试消息", |
| | | "self": False |
| | | } |
| | | } |
| | | |
| | | result = self.processor.is_valid_group_message(callback_data) |
| | | assert result is False |
| | | mock_friend_ignore_service.is_friend_ignored.assert_called_once_with("wxid_test123") |
| | | |
| | | @patch('app.services.message_processor.friend_ignore_service') |
| | | def test_is_valid_group_message_friend_not_ignored(self, mock_friend_ignore_service): |
| | | """测试好友不在忽略列表中的消息""" |
| | | mock_friend_ignore_service.is_friend_ignored.return_value = False |
| | | |
| | | callback_data = { |
| | | "messageType": "80001", |
| | | "data": { |
| | | "fromUser": "wxid_test123", |
| | | "fromGroup": "group123@chatroom", |
| | | "content": "测试消息", |
| | | "self": False |
| | | } |
| | | } |
| | | |
| | | result = self.processor.is_valid_group_message(callback_data) |
| | | assert result is True |
| | | mock_friend_ignore_service.is_friend_ignored.assert_called_once_with("wxid_test123") |
| | | |
| | | @patch('app.services.message_processor.redis_queue') |
| | | def test_enqueue_callback_message_success(self, mock_redis_queue): |