ДОбавил репо могни, трепозитории, репо пользователя, профилей, .editorconfig обновил хэндлеры

Author: AlexanderBazarov

.editorconfig

@@ -0,0 +1,8 @@
+root = true
+
+[*]
+end_of_line = lf
+insert_final_newline = true
+
+[*.java]
+indent_style = tab

pom.xml

@@ -80,6 +80,16 @@
             <artifactId>log4j-slf4j2-impl</artifactId>
             <version>2.20.0</version>
         </dependency>
+        <dependency>
+            <groupId>org.mongodb</groupId>
+            <artifactId>mongodb-driver-sync</artifactId>
+            <version>3.9.1</version>
+        </dependency>
+        <dependency>
+            <groupId>dev.morphia.morphia</groupId>
+            <artifactId>morphia-core</artifactId>
+            <version>2.4.14</version>
+        </dependency>
     </dependencies>
 
 

src/main/java/ru/untitled_devs/bot/Main.java

@@ -5,6 +5,7 @@
 import org.apache.logging.log4j.Logger;
 import org.telegram.telegrambots.meta.TelegramBotsApi;
 import org.telegram.telegrambots.updatesreceivers.DefaultBotSession;
+import ru.untitled_devs.bot.start.StartRouter;
 import ru.untitled_devs.core.client.Bot;
 import ru.untitled_devs.core.fsm.storage.InMemoryStorage;
 
@@ -18,9 +19,12 @@ public static void main(String[] args) {
         try {
             TelegramBotsApi botsApi = new TelegramBotsApi(DefaultBotSession.class);
             Bot bot = new Bot(config.getBotToken(), config.getBotName(), storage,logger);
+
+            bot.addRouter(new StartRouter(bot));
+
             botsApi.registerBot(bot);
         } catch (Exception e) {
             logger.error(e.getMessage());
         }
     }
-}
+}

src/main/java/ru/untitled_devs/bot/models/Model.java

@@ -0,0 +1,4 @@
+package ru.untitled_devs.bot.models;
+
+public interface Model {
+}

src/main/java/ru/untitled_devs/bot/models/Profile.java

@@ -0,0 +1,22 @@
+package ru.untitled_devs.bot.models;
+
+import com.mongodb.client.model.geojson.Point;
+import dev.morphia.annotations.Entity;
+import dev.morphia.annotations.Id;
+import org.bson.types.ObjectId;
+
+@Entity("Profiles")
+public class Profile implements Model {
+    @Id
+    private ObjectId id;
+
+    private String description;
+    private int age;
+    private String city;
+    private String image;
+
+    private Point coordinates;
+
+    private boolean show;
+
+}

src/main/java/ru/untitled_devs/bot/models/User.java

@@ -0,0 +1,20 @@
+package ru.untitled_devs.bot.models;
+
+import dev.morphia.annotations.Entity;
+import dev.morphia.annotations.Id;
+import dev.morphia.annotations.Reference;
+import org.bson.types.ObjectId;
+
+@Entity("Accounts")
+public class User implements Model{
+    @Id
+    private ObjectId id;
+
+    private int telegramId;
+    private String lang;
+    private boolean admin;
+    private boolean banned;
+
+    @Reference
+    private Profile profile;
+}

src/main/java/ru/untitled_devs/bot/registration/fsm/RegistrationStates.java

@@ -0,0 +1,16 @@
+package ru.untitled_devs.bot.registration.fsm;
+
+import ru.untitled_devs.core.fsm.states.State;
+import ru.untitled_devs.core.fsm.states.StatesGroup;
+
+public class RegistrationStates extends StatesGroup {
+    public static final State START = state();
+    public static final State NAME = state();
+    public static final State AGE = state();
+    public static final State LOCATION = state();
+    public static final State PHOTO = state();
+
+    static {
+        allStates(RegistrationStates.class);
+    }
+}

src/main/java/ru/untitled_devs/bot/registration/routes/RegistraitonRouter.java

@@ -0,0 +1,24 @@
+package ru.untitled_devs.bot.registration.routes;
+import org.telegram.telegrambots.meta.api.objects.Message;
+import ru.untitled_devs.bot.registration.fsm.RegistrationStates;
+import ru.untitled_devs.core.client.Bot;
+import ru.untitled_devs.core.fsm.context.FSMContext;
+import ru.untitled_devs.core.routers.Router;
+import ru.untitled_devs.core.routers.filters.Command;
+import ru.untitled_devs.core.routers.handlers.MessageHandler;
+
+public class RegistraitonRouter extends Router {
+    private final Bot bot;
+
+    public RegistraitonRouter(Bot bot) {
+        this.bot = bot;
+    }
+
+    private void registerHandlers() {
+        this.addHandler(RegistrationStates.START, new MessageHandler(this::startRegistration, new Command("start")));
+    }
+
+    private void startRegistration(Message message, FSMContext ctx) {
+
+    }
+}

src/main/java/ru/untitled_devs/bot/repositories/BaseRepo.java

@@ -0,0 +1,11 @@
+package ru.untitled_devs.bot.repositories;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface BaseRepo<T, ID> {
+	T save(T entity);
+	Optional<T> findById(ID id);
+	List<T> findAll();
+	void delete(T entity);
+}

src/main/java/ru/untitled_devs/bot/repositories/MongoRepo.java

@@ -0,0 +1,43 @@
+package ru.untitled_devs.bot.repositories;
+
+import dev.morphia.Datastore;
+import dev.morphia.query.MorphiaCursor;
+import org.bson.types.ObjectId;
+
+import java.util.List;
+import java.util.Optional;
+
+import static dev.morphia.query.filters.Filters.*;
+
+public abstract class MongoRepo<T> implements BaseRepo<T, ObjectId>{
+	private final Class<T> objectClass;
+	private final Datastore datastore;
+
+    protected MongoRepo(Datastore datastore, Class<T> objectClass) {
+		this.datastore = datastore;
+		this.objectClass = objectClass;
+    }
+
+	@Override
+	public T save(T entity) {
+		return this.datastore.save(entity);
+	}
+
+	@Override
+	public Optional<T> findById(ObjectId objectId) {
+		return Optional.ofNullable(this.datastore.find(objectClass)
+			.filter(eq("_id", objectId)).first());
+	}
+
+	@Override
+	public List<T> findAll() {
+		 try (MorphiaCursor<T> cursor = this.datastore.find(objectClass).iterator()) {
+			return cursor.toList();
+		 }
+	}
+
+	@Override
+	public void delete(T entity) {
+		datastore.delete(entity);
+	}
+}