Skip to content

W
whatsappweb
Commit 29d3aef0 by Mauro Paolo Josue Zuñiga Mallqui
Options

Initial Commit

parents
Showing with 612 additions and 0 deletions
.gitignore 0 → 100644
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
.mvn/wrapper/maven-wrapper.properties 0 → 100644
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
wrapperVersion=3.3.1
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.6/apache-maven-3.9.6-bin.zip
Dockerfile 0 → 100644
FROM openjdk:21
ARG JAR_FILE=target/*.war
COPY ${JAR_FILE} app.war
ENTRYPOINT ["java","-jar","/app.war"]
\ No newline at end of file
mvnw 0 → 100755
This diff is collapsed. Click to expand it.
mvnw.cmd 0 → 100644
<# : batch portion
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements. See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership. The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License. You may obtain a copy of the License at
@REM
@REM https://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied. See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------
@REM ----------------------------------------------------------------------------
@REM Apache Maven Wrapper startup batch script, version 3.3.1
@REM
@REM Optional ENV vars
@REM MVNW_REPOURL - repo url base for downloading maven distribution
@REM MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
@REM MVNW_VERBOSE - true: enable verbose log; others: silence the output
@REM ----------------------------------------------------------------------------
@IF "%__MVNW_ARG0_NAME__%"=="" (SET __MVNW_ARG0_NAME__=%~nx0)
@SET __MVNW_CMD__=
@SET __MVNW_ERROR__=
@SET __MVNW_PSMODULEP_SAVE=%PSModulePath%
@SET PSModulePath=
@FOR /F "usebackq tokens=1* delims==" %%A IN (`powershell -noprofile "& {$scriptDir='%~dp0'; $script='%__MVNW_ARG0_NAME__%'; icm -ScriptBlock ([Scriptblock]::Create((Get-Content -Raw '%~f0'))) -NoNewScope}"`) DO @(
IF "%%A"=="MVN_CMD" (set __MVNW_CMD__=%%B) ELSE IF "%%B"=="" (echo %%A) ELSE (echo %%A=%%B)
)
@SET PSModulePath=%__MVNW_PSMODULEP_SAVE%
@SET __MVNW_PSMODULEP_SAVE=
@SET __MVNW_ARG0_NAME__=
@SET MVNW_USERNAME=
@SET MVNW_PASSWORD=
@IF NOT "%__MVNW_CMD__%"=="" (%__MVNW_CMD__% %*)
@echo Cannot start maven from wrapper >&2 && exit /b 1
@GOTO :EOF
: end batch / begin powershell #>
$ErrorActionPreference = "Stop"
if ($env:MVNW_VERBOSE -eq "true") {
$VerbosePreference = "Continue"
}
# calculate distributionUrl, requires .mvn/wrapper/maven-wrapper.properties
$distributionUrl = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionUrl
if (!$distributionUrl) {
Write-Error "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
}
switch -wildcard -casesensitive ( $($distributionUrl -replace '^.*/','') ) {
"maven-mvnd-*" {
$USE_MVND = $true
$distributionUrl = $distributionUrl -replace '-bin\.[^.]*$',"-windows-amd64.zip"
$MVN_CMD = "mvnd.cmd"
break
}
default {
$USE_MVND = $false
$MVN_CMD = $script -replace '^mvnw','mvn'
break
}
}
# apply MVNW_REPOURL and calculate MAVEN_HOME
# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
if ($env:MVNW_REPOURL) {
$MVNW_REPO_PATTERN = if ($USE_MVND) { "/org/apache/maven/" } else { "/maven/mvnd/" }
$distributionUrl = "$env:MVNW_REPOURL$MVNW_REPO_PATTERN$($distributionUrl -replace '^.*'+$MVNW_REPO_PATTERN,'')"
}
$distributionUrlName = $distributionUrl -replace '^.*/',''
$distributionUrlNameMain = $distributionUrlName -replace '\.[^.]*$','' -replace '-bin$',''
$MAVEN_HOME_PARENT = "$HOME/.m2/wrapper/dists/$distributionUrlNameMain"
$MAVEN_HOME_NAME = ([System.Security.Cryptography.MD5]::Create().ComputeHash([byte[]][char[]]$distributionUrl) | ForEach-Object {$_.ToString("x2")}) -join ''
$MAVEN_HOME = "$MAVEN_HOME_PARENT/$MAVEN_HOME_NAME"
if (Test-Path -Path "$MAVEN_HOME" -PathType Container) {
Write-Verbose "found existing MAVEN_HOME at $MAVEN_HOME"
Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
exit $?
}
if (! $distributionUrlNameMain -or ($distributionUrlName -eq $distributionUrlNameMain)) {
Write-Error "distributionUrl is not valid, must end with *-bin.zip, but found $distributionUrl"
}
# prepare tmp dir
$TMP_DOWNLOAD_DIR_HOLDER = New-TemporaryFile
$TMP_DOWNLOAD_DIR = New-Item -Itemtype Directory -Path "$TMP_DOWNLOAD_DIR_HOLDER.dir"
$TMP_DOWNLOAD_DIR_HOLDER.Delete() | Out-Null
trap {
if ($TMP_DOWNLOAD_DIR.Exists) {
try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
}
}
New-Item -Itemtype Directory -Path "$MAVEN_HOME_PARENT" -Force | Out-Null
# Download and Install Apache Maven
Write-Verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
Write-Verbose "Downloading from: $distributionUrl"
Write-Verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
$webclient = New-Object System.Net.WebClient
if ($env:MVNW_USERNAME -and $env:MVNW_PASSWORD) {
$webclient.Credentials = New-Object System.Net.NetworkCredential($env:MVNW_USERNAME, $env:MVNW_PASSWORD)
}
[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12
$webclient.DownloadFile($distributionUrl, "$TMP_DOWNLOAD_DIR/$distributionUrlName") | Out-Null
# If specified, validate the SHA-256 sum of the Maven distribution zip file
$distributionSha256Sum = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionSha256Sum
if ($distributionSha256Sum) {
if ($USE_MVND) {
Write-Error "Checksum validation is not supported for maven-mvnd. `nPlease disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties."
}
Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash
if ((Get-FileHash "$TMP_DOWNLOAD_DIR/$distributionUrlName" -Algorithm SHA256).Hash.ToLower() -ne $distributionSha256Sum) {
Write-Error "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised. If you updated your Maven version, you need to update the specified distributionSha256Sum property."
}
}
# unzip and move
Expand-Archive "$TMP_DOWNLOAD_DIR/$distributionUrlName" -DestinationPath "$TMP_DOWNLOAD_DIR" | Out-Null
Rename-Item -Path "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" -NewName $MAVEN_HOME_NAME | Out-Null
try {
Move-Item -Path "$TMP_DOWNLOAD_DIR/$MAVEN_HOME_NAME" -Destination $MAVEN_HOME_PARENT | Out-Null
} catch {
if (! (Test-Path -Path "$MAVEN_HOME" -PathType Container)) {
Write-Error "fail to move MAVEN_HOME"
}
} finally {
try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
}
Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.2.6</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>sacooliveros</groupId>
<artifactId>whatsappweb</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>war</packaging>
<name>whatsappweb</name>
<description>Api for Whatsapp web</description>
<properties>
<java.version>21</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.github.auties00</groupId>
<artifactId>cobalt</artifactId>
<version>0.0.5</version>
</dependency>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
<version>20240303</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.32</version>
<scope>provided</scope>
</dependency>
</dependencies>
<build>
<finalName>whatsappweb</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<annotationProcessorPaths>
<annotationProcessorPath>
<groupId>com.github.auties00</groupId>
<artifactId>cobalt</artifactId>
<version>0.0.5</version>
</annotationProcessorPath>
</annotationProcessorPaths>
</configuration>
</plugin>
</plugins>
</build>
</project>
src/main/java/sacooliveros/whatsappweb/ServletInitializer.java 0 → 100644
package sacooliveros.whatsappweb;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
public class ServletInitializer extends SpringBootServletInitializer {
@Override
protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
return application.sources(WhatsappwebApplication.class);
}
}
src/main/java/sacooliveros/whatsappweb/WhatsappwebApplication.java 0 → 100644
package sacooliveros.whatsappweb;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class WhatsappwebApplication {
public static void main(String[] args) {
SpringApplication.run(WhatsappwebApplication.class, args);
}
}
src/main/java/sacooliveros/whatsappweb/api/WhatsappRest.java 0 → 100644
package sacooliveros.whatsappweb.api;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
import java.util.logging.Logger;
import org.apache.catalina.connector.Response;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import it.auties.whatsapp.api.Whatsapp;
import sacooliveros.whatsappweb.bean.WhatsappBean;
import sacooliveros.whatsappweb.service.WhatsappService;
import sacooliveros.whatsappweb.utils.WhatsappUtils;
@RestController
@CrossOrigin("*")
@RequestMapping("api/v1")
public class WhatsappRest {
Logger logger = Logger.getLogger(WhatsappRest.class.getName());
WhatsappBean whatsappBean;
WhatsappService whatsappService;
public WhatsappRest(WhatsappBean whatsappBean, WhatsappService whatsappService) {
this.whatsappBean = whatsappBean;
this.whatsappService = whatsappService;
}
@GetMapping("qr")
public ResponseEntity<?> getQR() {
Whatsapp w = whatsappBean.getWhatsapp();
WhatsappUtils utils = new WhatsappUtils();
if (w == null) {
return ResponseEntity.status(Response.SC_OK).body(utils.generateQR());
}
if (w.isConnected()) {
return ResponseEntity.status(Response.SC_OK).body("Already connected");
}
try {
w.connect().get(5, TimeUnit.SECONDS);
} catch (InterruptedException | ExecutionException | TimeoutException e) {
logger.severe(e.getMessage());
return ResponseEntity.status(Response.SC_INTERNAL_SERVER_ERROR).body("Connection failed");
}
if (!w.isConnected()) {
return ResponseEntity.status(Response.SC_INTERNAL_SERVER_ERROR).body("Connection failed");
}else{
return ResponseEntity.status(Response.SC_INTERNAL_SERVER_ERROR).body("Try logging out first");
}
}
@GetMapping("logout")
public ResponseEntity<?> logout() {
Whatsapp w = whatsappBean.getWhatsapp();
if (w == null) {
return ResponseEntity.status(Response.SC_OK).body("Not connected");
}
try {
w.disconnect().get(5, TimeUnit.SECONDS);
w.logout().get(5, TimeUnit.SECONDS);
return ResponseEntity.status(Response.SC_OK).body("Logged out");
} catch (InterruptedException | ExecutionException | TimeoutException e) {
logger.severe(e.getMessage());
return ResponseEntity.status(Response.SC_INTERNAL_SERVER_ERROR).body("Logout failed");
}
}
@PostMapping(value = "send", consumes = MediaType.MULTIPART_FORM_DATA_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<?> send(@RequestParam Map<String, String> payload, @RequestParam Map<String, MultipartFile> files) {
Whatsapp w = whatsappBean.getWhatsapp();
if (w == null) {
return ResponseEntity.status(Response.SC_OK).body("Not connected");
}
try{
w.connect().get(10, TimeUnit.SECONDS);
if (w.isConnected()) {
whatsappService.send(payload, files, w);
return ResponseEntity.status(Response.SC_OK).body(payload);
}else{
return ResponseEntity.status(Response.SC_OK).body("Not connected");
}
}catch (Exception e){
logger.severe(e.getMessage());
return ResponseEntity.status(Response.SC_INTERNAL_SERVER_ERROR).body("Send failed");
}
}
}
src/main/java/sacooliveros/whatsappweb/bean/WhatsappBean.java 0 → 100644
package sacooliveros.whatsappweb.bean;
import java.util.Optional;
import org.springframework.stereotype.Component;
import it.auties.whatsapp.api.Whatsapp;
@Component
public class WhatsappBean {
Optional<Whatsapp> w = Whatsapp.webBuilder().lastConnection().registered();
public Whatsapp getWhatsapp() {
return w.orElse(null);
}
}
src/main/java/sacooliveros/whatsappweb/listener/LogInListener.java 0 → 100644
package sacooliveros.whatsappweb.listener;
import it.auties.whatsapp.listener.OnLoggedIn;
import it.auties.whatsapp.listener.RegisterListener;
@RegisterListener
public class LogInListener implements OnLoggedIn {
@Override
public void onLoggedIn() {
System.out.println("Logged in");
}
}
src/main/java/sacooliveros/whatsappweb/service/WhatsappService.java 0 → 100644
package sacooliveros.whatsappweb.service;
import java.io.IOException;
import java.util.*;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import io.netty.util.Timeout;
import it.auties.whatsapp.api.Whatsapp;
import it.auties.whatsapp.model.contact.Contact;
import it.auties.whatsapp.model.jid.Jid;
import it.auties.whatsapp.model.jid.JidServer;
import it.auties.whatsapp.model.message.standard.*;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
@Service
public class WhatsappService {
public void send(Map<String, String> payload, Map<String, MultipartFile> files, Whatsapp whatsapp) {
List<String> numbers = new ArrayList<>(Arrays.asList(payload.get("numbers").split(",")));
String message = payload.get("message");
for (String number : numbers) {
Jid jid = new Jid(number, JidServer.WHATSAPP, null, null);
Contact contact = new Contact(jid);
whatsapp.sendChatMessage(contact, message);
if (files != null) {
for (MultipartFile file : files.values()) {
String extension = Objects.requireNonNull(file.getOriginalFilename())
.substring(file.getOriginalFilename().lastIndexOf("."));
switch (extension) {
case ".jpg", ".jpeg", ".png" -> sendImage(file, whatsapp, contact);
case ".mp4" -> sendVideo(file, whatsapp, contact);
case ".mp3" -> sendAudio(file, whatsapp, contact);
default -> sendDocument(file, whatsapp, contact);
}
}
}
}
}
public void sendImage(MultipartFile file, Whatsapp whatsapp, Contact contact) {
try {
byte[] bytes = file.getBytes();
ImageMessage imageMessage = new ImageMessageSimpleBuilder()
.media(bytes)
.build();
whatsapp.sendMessage(contact, imageMessage).get(10, TimeUnit.SECONDS);
} catch (IOException | InterruptedException | ExecutionException | TimeoutException e) {
throw new RuntimeException(e);
}
}
public void sendVideo(MultipartFile file, Whatsapp whatsapp, Contact contact) {
try{
byte[] bytes = file.getBytes();
VideoOrGifMessage videoMessage = new VideoMessageSimpleBuilder()
.media(bytes)
.build();
whatsapp.sendMessage(contact,videoMessage).get(10, TimeUnit.SECONDS);
} catch (IOException | InterruptedException | ExecutionException | TimeoutException e) {
throw new RuntimeException(e);
}
}
public void sendAudio(MultipartFile file, Whatsapp whatsapp, Contact contact) {
try{
byte[] bytes = file.getBytes();
AudioMessage audioMessage = new AudioMessageSimpleBuilder()
.media(bytes)
.build();
whatsapp.sendMessage(contact,audioMessage).get(10, TimeUnit.SECONDS);
} catch (IOException | InterruptedException | ExecutionException | TimeoutException e) {
throw new RuntimeException(e);
}
}
public void sendDocument(MultipartFile file, Whatsapp whatsapp, Contact contact) {
try{
byte[] bytes = file.getBytes();
DocumentMessage documentMessage = new DocumentMessageSimpleBuilder()
.media(bytes)
.fileName(file.getOriginalFilename())
.build();
whatsapp.sendMessage(contact,documentMessage).get(10, TimeUnit.SECONDS);
} catch (IOException | InterruptedException | ExecutionException | TimeoutException e) {
throw new RuntimeException(e);
}
}
}
\ No newline at end of file
src/main/java/sacooliveros/whatsappweb/utils/WhatsappUtils.java 0 → 100644
package sacooliveros.whatsappweb.utils;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.function.Consumer;
import java.util.logging.Level;
import java.util.logging.Logger;
import it.auties.whatsapp.api.QrHandler;
import it.auties.whatsapp.api.Whatsapp;
public class WhatsappUtils {
Logger logger = Logger.getLogger(WhatsappUtils.class.getName());
public String generateQR() {
StringBuilder qr = new StringBuilder();
CountDownLatch latch = new CountDownLatch(1);
Consumer<String> smallQrConsumer = qrCode -> {
qr.append(qrCode);
latch.countDown();
};
try {
CompletableFuture.supplyAsync(() ->
Whatsapp.webBuilder()
.lastConnection()
.unregistered(QrHandler.toString(smallQrConsumer))
.connect()
.join()
).get(10, TimeUnit.SECONDS);
if (!latch.await(10, TimeUnit.SECONDS)) {
throw new TimeoutException("QR generation timed out");
}
} catch (TimeoutException e) {
logger.log(Level.WARNING, "QR generation timeout", e);
return "QR generation timeout";
} catch (Exception e) {
logger.log(Level.SEVERE, "QR generation failed", e);
return "QR generation failed";
}
return qr.toString();
}
}
src/main/resources/application.properties 0 → 100644
spring.application.name=whatsappweb
server.port=8083
\ No newline at end of file
src/test/java/sacooliveros/whatsappweb/WhatsappwebApplicationTests.java 0 → 100644
package sacooliveros.whatsappweb;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class WhatsappwebApplicationTests {
@Test
void contextLoads() {
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment