Skip to content

Refactor to module based pattern #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
oelburk merged 9 commits into from
Jan 24, 2025
Merged

Refactor to module based pattern #8

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
657a261
Update dependencies, refactor beer agent to module
oelburk Jul 25, 2023
fbfd3c6
Refactor untappd service to module
oelburk Jul 25, 2023
d724f7e
Clean up hive references
oelburk Jul 25, 2023
2fe75a6
Unload beer agent module
oelburk Jul 25, 2023
38ab055
Clean up missed refs to beer agent, add init checks
oelburk Jul 25, 2023
8be7ed3
Make untappd module a singleton
oelburk Jul 29, 2023
8e2c9e6
Merge remote-tracking branch 'origin/master' into refactor-bot-modules
Mar 22, 2024
d11a619
remove deprecated in favour for analyzer
oelburk Mar 22, 2024
e73641a
Merge remote-tracking branch 'origin/master' into refactor-bot-modules
oelburk Jan 24, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
200 changes: 7 additions & 193 deletions bin/beer_bot.dart
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,28 +1,16 @@
import 'dart:async';
import 'package:hive/hive.dart';
import 'dart:io';

import 'package:nyxx/nyxx.dart';
import 'package:http/http.dart' as http;
import 'package:nyxx_interactions/nyxx_interactions.dart';
import 'dart:convert';
import 'dart:io';
import 'beer.dart';
import 'beerlist.dart';

import 'commands.dart';
import 'constants/hive_constants.dart';
import 'untapped_service.dart';
import 'utils.dart';
import 'package:intl/intl.dart';
import 'modules/untappd/untapped_module.dart';

String BOT_TOKEN = Platform.environment['DISCORD_TOKEN'] ?? '';
late final Stopwatch ELAPSED_SINCE_UPDATE;
List<BeerList> BEER_SALES = <BeerList>[];
int REFRESH_THRESHOLD = 14400000;

late final INyxxWebsocket bot;

void main(List<String> arguments) {
Hive.init('/data');
Hive.openBox(HiveConstants.untappdBox);

bot =
NyxxFactory.createNyxxWebsocket(BOT_TOKEN, GatewayIntents.allUnprivileged)
..registerPlugin(Logging())
Expand All @@ -38,184 +26,10 @@ void main(List<String> arguments) {

interactions.syncOnReady();

ELAPSED_SINCE_UPDATE = Stopwatch();

bot.eventsWs.onReady.listen((e) {
print('Agent Hops is ready!');
});

Timer.periodic(Duration(hours: 6), (timer) => updateSubscribers());

Timer.periodic(Duration(minutes: 12), (timer) => checkUntappd());
}

void checkUntappd() async {
var box = await Hive.box(HiveConstants.untappdBox);

Map<dynamic, dynamic> listOfUsers =
await box.get(HiveConstants.untappdUserList, defaultValue: {});
var latestCheckins =
await box.get(HiveConstants.untappdLatestUserCheckins, defaultValue: {});

var updateChannelId = await box.get(HiveConstants.untappdUpdateChannelId);

if (updateChannelId == null) {
print('No channel available for updates!');
return;
}

if (listOfUsers.isEmpty) print('No users available to scrape!');

listOfUsers.forEach((userSnowflake, untappdUsername) async {
var latestCheckinDisk = latestCheckins[untappdUsername];
try {
var latestCheckinUntappd =
await UntappdService.getLatestCheckin(untappdUsername);

// If a new ID is available, post update!
if (latestCheckinUntappd != null &&
latestCheckinDisk != latestCheckinUntappd.id) {
// Update latest saved checkin
latestCheckins.addAll({untappdUsername: latestCheckinUntappd.id});
await box.put(HiveConstants.untappdLatestUserCheckins, latestCheckins);

// Build update message with info from untappd checkin
var user = await bot.fetchUser(Snowflake(userSnowflake));
var embedBuilder = EmbedBuilder();
embedBuilder.title = '${user.username} is drinking beer!';
embedBuilder.url = UntappdService.getCheckinUrl(
latestCheckinUntappd.id, untappdUsername);
embedBuilder.description = latestCheckinUntappd.title;
if (latestCheckinUntappd.comment.isNotEmpty) {
embedBuilder.addField(
field:
EmbedFieldBuilder('Comment', latestCheckinUntappd.comment));
}
if (latestCheckinUntappd.rating.isNotEmpty) {
embedBuilder.addField(
field: EmbedFieldBuilder(
'Rating',
_buildRatingEmoji(
double.parse(latestCheckinUntappd.rating))));
}
if (latestCheckinUntappd.photoAddress != null) {
embedBuilder.imageUrl = latestCheckinUntappd.photoAddress;
}

// Get channel used for untappd updates, previously set by discord admin.
var updateChannel = await bot
.fetchChannel(Snowflake(updateChannelId))
.then((value) => (value as ITextChannel));

// Send update message
await updateChannel.sendMessage(MessageBuilder.embed(embedBuilder));
}
// Sleep 5 seconds per user to avoid suspicious requests to untappd server
await Future.delayed(Duration(seconds: 5));
} catch (e) {
print(e.toString());
}
});
}

String _buildRatingEmoji(double rating) {
var ratingString = '';
for (var i = 0; i < rating.toInt(); i++) {
ratingString += ':beer: ';
}
return '$ratingString ($rating)';
}

Future<void> updateSubscribers() async {
await requestBeer();

var myFile = File('sub.dat');
var shouldInform = false;
var beers = <Beer>[];
var saleDate;

if (!await myFile.exists()) return;

for (var sale in BEER_SALES) {
saleDate = DateTime.parse(sale.saleDate);
var currentDate =
DateTime(DateTime.now().year, DateTime.now().month, DateTime.now().day);
if (saleDate.difference(currentDate).inDays == 1) {
//Inform subscribing users about upcoming sale...
shouldInform = true;
print('Sale is going down!');
beers = sale.beerList;
break;
}
//No sale is closer than 1 day -> do nothing...
}

if (shouldInform) {
for (var dmchannel in await getSubChannels(bot)) {
var beersStr = '';
beers.forEach((element) {
beersStr += '- ' + element.name + '\n';
});

var updateMessage = MessageBuilder()
..append(':beers: Hey!')
..appendNewLine()
..append('There is a fresh beer release tomorrow, ')
..appendBold(DateFormat('yyyy-MM-dd').format(saleDate))
..append('. Bolaget opens 10:00')
..appendNewLine()
..append('There are ')
..appendBold(beers.length.toString())
..append(' new beers tomorrow.')
..appendNewLine()
..append('For more info, visit https://systembevakningsagenten.se/')
..appendNewLine()
..appendNewLine()
..append(beersStr);

//To avoid hitting maximum characters for a message, limit output to 2000.
if (updateMessage.toString().length > 2000) {
updateMessage.content =
updateMessage.content.substring(0, 1992) + '...\n\n';
}
await dmchannel.sendMessage(updateMessage);
}
} else {
print('No sale, boring...');
}
}

Future requestBeer() async {
//Only update list if older than 4 hours or empty
if (ELAPSED_SINCE_UPDATE.elapsedMilliseconds > REFRESH_THRESHOLD ||
BEER_SALES.isEmpty) {
ELAPSED_SINCE_UPDATE.stop();
print('Updating beer releases and beers...');
final list = await fetchBeerList();
BEER_SALES.clear();
for (var item in list['release']) {
BEER_SALES.add(BeerList.fromJson(item));
}
ELAPSED_SINCE_UPDATE.reset();
ELAPSED_SINCE_UPDATE.start();
} else {
print('No update needed, requires update in ' +
(((REFRESH_THRESHOLD - ELAPSED_SINCE_UPDATE.elapsedMilliseconds) /
1000) ~/
60)
.toString() +
' minutes.');
}
}

Future<Map<String, dynamic>> fetchBeerList() async {
final response = await http.get(Uri.parse(
'https://systembevakningsagenten.se/api/json/2.0/newProducts.json'));

if (response.statusCode == 200) {
Map<String, dynamic> res = json.decode(response.body);
return res;
} else {
throw Exception('Error fetching beer information');
}
// Initialize bot modules
UntappdModule().init(bot);
}
19 changes: 0 additions & 19 deletions bin/beerlist.dart
View file
Open in desktop

This file was deleted.

Loading
Loading