source: src/main/java/com/example/baziproekt/service/impl/KorisniciServiceImpl.java@ 0e4d807

package com.example.baziproekt.service.impl;

import com.example.baziproekt.model.*;
import com.example.baziproekt.model.exceptions.InvalidArgumentsException;
import com.example.baziproekt.model.exceptions.InvalidUserCredentialsException;
import com.example.baziproekt.model.exceptions.UserAlreadyExistException;
import com.example.baziproekt.model.exceptions.UserNotFoundException;
import com.example.baziproekt.repository.KorisniciRepository;
import com.example.baziproekt.service.KorisniciService;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UsernameNotFoundException;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class KorisniciServiceImpl implements KorisniciService {

    private final KorisniciRepository repository;

    public KorisniciServiceImpl(KorisniciRepository repository) {
        this.repository = repository;
    }

    @Override
    public List<Korisnici> findAll() {
        return repository.findAll();
    }

    @Override
    public Korisnici findByIme(String korisnicko_ime) {

        return repository.findKorisniciByIme(korisnicko_ime);
    }


    @Override
    public Korisnici login(String username, String password) {

        if(username == null || username.isEmpty() || password == null || password.isEmpty())
        {
            throw new InvalidArgumentsException();
        }

        return repository.findKorisniciByImeAndLozinka(username, password).orElseThrow(InvalidUserCredentialsException::new);
    }

    @Override
    public Korisnici delete(String ime) {
        Korisnici korisnici=this.findByIme(ime);
        repository.delete(korisnici);
        return korisnici;
    }

    @Override
    public void create(String username, String password, Roles role,String email) {
       /* Korisnici korisnici;
        try {
            Korisnici k = this.findByIme(username);
        } catch (UserNotFoundException e) {
            korisnici = new Korisnici(username, password, email, role);
            return repository.save(korisnici);
        }
        throw new UserAlreadyExistException();*/
        if(role.equals(Roles.ROLES_KUPUVAC))
        {
            repository.save(new Kupuvaci(username,password,email));
        }
        else if(role.equals(Roles.ROLES_DOSTAVUVAC))
        {
            repository.save(new Dostavuvaci(username,password,email));
        }
        else
        {
            repository.save(new Vraboteni(username,password,email));
        }

    }



    @Override
    public Korisnici update( String ime, String lozinka,String email, String tel) {
        Korisnici k=this.findByIme(ime);
        k.setIme(ime);
        k.setLozinka(lozinka);
        k.setBroj(tel);
        k.setEmail(email);
        return repository.save(k);
    }


    @Override
    public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
        return this.findByIme(username);
    }
}