ShanmugaKrishnanSM/RIT-nexus
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

telegram updated

Browse Source
This commit is contained in:
Devesh S
2026-07-22 14:41:42 +05:30
parent 163e9f93f2
commit b8b62bed66
1 changed files with 6 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
backend/src/main/java/com/rit/portal/controller/CommunityQuestionController.java
View File

@@ -5,10 +5,6 @@ import com.rit.portal.entity.CommunityQuestion;
import com.rit.portal.repository.CommunityAnswerRepository; import com.rit.portal.repository.CommunityAnswerRepository;
import com.rit.portal.repository.CommunityQuestionRepository; import com.rit.portal.repository.CommunityQuestionRepository;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
@@ -30,33 +26,19 @@ public class CommunityQuestionController {
private final RestTemplate restTemplate = new RestTemplate(); private final RestTemplate restTemplate = new RestTemplate();
private static final String TELEGRAM_BOT_URL = "http://localhost:8082/send_question"; private static final String TELEGRAM_BOT_URL = "http://localhost:8082/send_question";
/** Legacy – returns all questions (kept for backwards compatibility) */
@GetMapping @GetMapping
public List<CommunityQuestion> getAllQuestions() { public List<CommunityQuestion> getAllQuestions() {
return questionRepository.findAll(); return questionRepository.findAll();
} }
/**
* Paginated – returns a Spring Page of questions ordered newest-first.
* Usage: GET /api/questions/paged?page=0&size=5
* Response includes: content[], totalElements, totalPages, number (current page), last (boolean)
*/
@GetMapping("/paged")
public Page<CommunityQuestion> getQuestionsPaged(
@RequestParam(defaultValue = "0") int page,
@RequestParam(defaultValue = "5") int size) {
Pageable pageable = PageRequest.of(page, size, Sort.by(Sort.Direction.DESC, "createdAt"));
return questionRepository.findAll(pageable);
}
@PostMapping @PostMapping
public CommunityQuestion createQuestion(@RequestBody CommunityQuestion question) { public CommunityQuestion createQuestion(@RequestBody CommunityQuestion question) {
if (question.getUpvotes() == null) question.setUpvotes(0); if (question.getUpvotes() == null) question.setUpvotes(0);
if (question.getIsAnswered() == null) question.setIsAnswered(false); if (question.getIsAnswered() == null) question.setIsAnswered(false);
question.setCreatedAt(LocalDateTime.now()); question.setCreatedAt(LocalDateTime.now());
CommunityQuestion saved = questionRepository.save(question); CommunityQuestion saved = questionRepository.save(question);
// Notify Telegram bot in a background thread to keep it robust and non-blocking // Notify Telegram bot in a background thread to keep it robust and non-blocking
new Thread(() -> { new Thread(() -> {
try { try {
@@ -65,7 +47,7 @@ public class CommunityQuestionController {
payload.put("title", saved.getTitle()); payload.put("title", saved.getTitle());
payload.put("body", saved.getBody()); payload.put("body", saved.getBody());
payload.put("author", saved.getAuthor()); payload.put("author", saved.getAuthor());
restTemplate.postForEntity(TELEGRAM_BOT_URL, payload, String.class); restTemplate.postForEntity(TELEGRAM_BOT_URL, payload, String.class);
} catch (Exception e) { } catch (Exception e) {
System.err.println("Failed to notify Telegram Bot intermediary: " + e.getMessage()); System.err.println("Failed to notify Telegram Bot intermediary: " + e.getMessage());
@@ -82,12 +64,12 @@ public class CommunityQuestionController {
if (answer.getUpvotes() == null) answer.setUpvotes(0); if (answer.getUpvotes() == null) answer.setUpvotes(0);
if (answer.getIsAccepted() == null) answer.setIsAccepted(false); if (answer.getIsAccepted() == null) answer.setIsAccepted(false);
answer.setCreatedAt(LocalDateTime.now()); answer.setCreatedAt(LocalDateTime.now());
CommunityAnswer savedAnswer = answerRepository.save(answer); CommunityAnswer savedAnswer = answerRepository.save(answer);
question.setIsAnswered(true); question.setIsAnswered(true);
questionRepository.save(question); questionRepository.save(question);
return ResponseEntity.ok(savedAnswer); return ResponseEntity.ok(savedAnswer);
}).orElse(ResponseEntity.notFound().build()); }).orElse(ResponseEntity.notFound().build());
} }